bldr/plugin/plugin.pb.go
Rama master · réplica de lectura del repositorio original.
// Code generated by protoc-gen-go-lite. DO NOT EDIT.
// protoc-gen-go-lite version: v0.19.1-0.20261028131920-f644656fc4a7
// source: github.com/s4wave/spacewave/bldr/plugin/plugin.proto
package bldr_plugin
import (
fmt "fmt"
io "io"
slices "slices"
strconv "strconv"
protobuf_go_lite "github.com/aperturerobotics/protobuf-go-lite"
json "github.com/aperturerobotics/protobuf-go-lite/json"
timestamppb "github.com/aperturerobotics/protobuf-go-lite/types/known/timestamppb"
manifest "github.com/s4wave/spacewave/bldr/manifest"
volume "github.com/s4wave/spacewave/db/volume"
)
// PluginState is the scheduler state for a plugin instance.
type PluginState int32
const (
// PluginState_UNKNOWN indicates the scheduler has no state yet.
PluginState_PluginState_UNKNOWN PluginState = 0
// PluginState_REQUESTED indicates the plugin has an active reference but no RPC client yet.
PluginState_PluginState_REQUESTED PluginState = 1
// PluginState_RUNNING indicates the plugin RPC client is ready.
PluginState_PluginState_RUNNING PluginState = 2
)
// Enum value maps for PluginState.
var (
PluginState_name = map[int32]string{
0: "PluginState_UNKNOWN",
1: "PluginState_REQUESTED",
2: "PluginState_RUNNING",
}
PluginState_value = map[string]int32{
"PluginState_UNKNOWN": 0,
"PluginState_REQUESTED": 1,
"PluginState_RUNNING": 2,
}
)
func (x PluginState) Enum() *PluginState {
p := new(PluginState)
*p = x
return p
}
func (x PluginState) String() string {
name, valid := PluginState_name[int32(x)]
if valid {
return name
}
return strconv.Itoa(int(x))
}
// PluginStatus holds basic status for a plugin.
type PluginStatus struct {
unknownFields []byte
// PluginId is the plugin identifier.
PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"pluginId,omitempty"`
// Running indicates the plugin is running.
Running bool `protobuf:"varint,2,opt,name=running,proto3" json:"running,omitempty"`
// InstanceKey is the optional instance key for instanced plugins.
InstanceKey string `protobuf:"bytes,3,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
// State is the scheduler state for this plugin instance.
State PluginState `protobuf:"varint,4,opt,name=state,proto3" json:"state,omitempty"`
// LastErrorMessage is the most recent plugin execution error summary.
LastErrorMessage string `protobuf:"bytes,5,opt,name=last_error_message,json=lastErrorMessage,proto3" json:"lastErrorMessage,omitempty"`
// LastErrorAt is when LastErrorMessage was recorded.
LastErrorAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_error_at,json=lastErrorAt,proto3" json:"lastErrorAt,omitempty"`
}
func (x *PluginStatus) Reset() {
*x = PluginStatus{}
}
func (*PluginStatus) ProtoMessage() {}
func (x *PluginStatus) GetPluginId() string {
if x != nil {
return x.PluginId
}
return ""
}
func (x *PluginStatus) GetRunning() bool {
if x != nil {
return x.Running
}
return false
}
func (x *PluginStatus) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
func (x *PluginStatus) GetState() PluginState {
if x != nil {
return x.State
}
return PluginState_PluginState_UNKNOWN
}
func (x *PluginStatus) GetLastErrorMessage() string {
if x != nil {
return x.LastErrorMessage
}
return ""
}
func (x *PluginStatus) GetLastErrorAt() *timestamppb.Timestamp {
if x != nil {
return x.LastErrorAt
}
return nil
}
// PluginManifestRecoveryStatus describes the retained Manifest selection and
// eligibility facts for one plugin instance.
type PluginManifestRecoveryStatus struct {
unknownFields []byte
// PluginId is the plugin identifier.
PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"pluginId,omitempty"`
// InstanceKey is the optional instance key for instanced plugins.
InstanceKey string `protobuf:"bytes,2,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
// ExecuteManifestRef is the ref of the manifest selected for execution.
ExecuteManifestRef string `protobuf:"bytes,3,opt,name=execute_manifest_ref,json=executeManifestRef,proto3" json:"executeManifestRef,omitempty"`
// DownloadManifestRef is the ref of the manifest selected for download.
DownloadManifestRef string `protobuf:"bytes,4,opt,name=download_manifest_ref,json=downloadManifestRef,proto3" json:"downloadManifestRef,omitempty"`
// SkippedCandidateCount is how many candidates were skipped.
SkippedCandidateCount uint32 `protobuf:"varint,5,opt,name=skipped_candidate_count,json=skippedCandidateCount,proto3" json:"skippedCandidateCount,omitempty"`
// SkippedCandidateSummary summarizes the skipped candidates.
SkippedCandidateSummary string `protobuf:"bytes,6,opt,name=skipped_candidate_summary,json=skippedCandidateSummary,proto3" json:"skippedCandidateSummary,omitempty"`
// IgnoredCandidateCount is how many candidates were ignored.
IgnoredCandidateCount uint32 `protobuf:"varint,7,opt,name=ignored_candidate_count,json=ignoredCandidateCount,proto3" json:"ignoredCandidateCount,omitempty"`
// IgnoredCandidateSummary summarizes the ignored candidates.
IgnoredCandidateSummary string `protobuf:"bytes,8,opt,name=ignored_candidate_summary,json=ignoredCandidateSummary,proto3" json:"ignoredCandidateSummary,omitempty"`
// QuarantinedCandidateCount is how many candidates were quarantined.
QuarantinedCandidateCount uint32 `protobuf:"varint,9,opt,name=quarantined_candidate_count,json=quarantinedCandidateCount,proto3" json:"quarantinedCandidateCount,omitempty"`
// QuarantinedCandidateSummary summarizes the quarantined candidates.
QuarantinedCandidateSummary string `protobuf:"bytes,10,opt,name=quarantined_candidate_summary,json=quarantinedCandidateSummary,proto3" json:"quarantinedCandidateSummary,omitempty"`
}
func (x *PluginManifestRecoveryStatus) Reset() {
*x = PluginManifestRecoveryStatus{}
}
func (*PluginManifestRecoveryStatus) ProtoMessage() {}
func (x *PluginManifestRecoveryStatus) GetPluginId() string {
if x != nil {
return x.PluginId
}
return ""
}
func (x *PluginManifestRecoveryStatus) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
func (x *PluginManifestRecoveryStatus) GetExecuteManifestRef() string {
if x != nil {
return x.ExecuteManifestRef
}
return ""
}
func (x *PluginManifestRecoveryStatus) GetDownloadManifestRef() string {
if x != nil {
return x.DownloadManifestRef
}
return ""
}
func (x *PluginManifestRecoveryStatus) GetSkippedCandidateCount() uint32 {
if x != nil {
return x.SkippedCandidateCount
}
return 0
}
func (x *PluginManifestRecoveryStatus) GetSkippedCandidateSummary() string {
if x != nil {
return x.SkippedCandidateSummary
}
return ""
}
func (x *PluginManifestRecoveryStatus) GetIgnoredCandidateCount() uint32 {
if x != nil {
return x.IgnoredCandidateCount
}
return 0
}
func (x *PluginManifestRecoveryStatus) GetIgnoredCandidateSummary() string {
if x != nil {
return x.IgnoredCandidateSummary
}
return ""
}
func (x *PluginManifestRecoveryStatus) GetQuarantinedCandidateCount() uint32 {
if x != nil {
return x.QuarantinedCandidateCount
}
return 0
}
func (x *PluginManifestRecoveryStatus) GetQuarantinedCandidateSummary() string {
if x != nil {
return x.QuarantinedCandidateSummary
}
return ""
}
// PluginStatusSnapshot describes a plugin host scheduler's plugin instances.
type PluginStatusSnapshot struct {
unknownFields []byte
// Plugins lists the per-instance statuses sorted by plugin id and instance key.
Plugins []*PluginStatus `protobuf:"bytes,1,rep,name=plugins,proto3" json:"plugins,omitempty"`
// ManifestRecovery lists the per-instance manifest selection facts sorted by
// plugin id and instance key.
ManifestRecovery []*PluginManifestRecoveryStatus `protobuf:"bytes,2,rep,name=manifest_recovery,json=manifestRecovery,proto3" json:"manifestRecovery,omitempty"`
}
func (x *PluginStatusSnapshot) Reset() {
*x = PluginStatusSnapshot{}
}
func (*PluginStatusSnapshot) ProtoMessage() {}
func (x *PluginStatusSnapshot) GetPlugins() []*PluginStatus {
if x != nil {
return x.Plugins
}
return nil
}
func (x *PluginStatusSnapshot) GetManifestRecovery() []*PluginManifestRecoveryStatus {
if x != nil {
return x.ManifestRecovery
}
return nil
}
// CheckActivationRequest queries the running generation's replacement contract.
type CheckActivationRequest struct {
unknownFields []byte
}
func (x *CheckActivationRequest) Reset() {
*x = CheckActivationRequest{}
}
func (*CheckActivationRequest) ProtoMessage() {}
// CheckActivationResponse confirms support for staged replacement.
type CheckActivationResponse struct {
unknownFields []byte
}
func (x *CheckActivationResponse) Reset() {
*x = CheckActivationResponse{}
}
func (*CheckActivationResponse) ProtoMessage() {}
// ActivatePluginRequest asks a ready candidate to become the current generation.
type ActivatePluginRequest struct {
unknownFields []byte
}
func (x *ActivatePluginRequest) Reset() {
*x = ActivatePluginRequest{}
}
func (*ActivatePluginRequest) ProtoMessage() {}
// ActivatePluginResponse confirms admission of the complete registration set.
type ActivatePluginResponse struct {
unknownFields []byte
}
func (x *ActivatePluginResponse) Reset() {
*x = ActivatePluginResponse{}
}
func (*ActivatePluginResponse) ProtoMessage() {}
// PrepareUpdateRequest asks the current generation to relinquish its work.
type PrepareUpdateRequest struct {
unknownFields []byte
}
func (x *PrepareUpdateRequest) Reset() {
*x = PrepareUpdateRequest{}
}
func (*PrepareUpdateRequest) ProtoMessage() {}
// PrepareUpdateResponse confirms the generation is ready for replacement.
type PrepareUpdateResponse struct {
unknownFields []byte
}
func (x *PrepareUpdateResponse) Reset() {
*x = PrepareUpdateResponse{}
}
func (*PrepareUpdateResponse) ProtoMessage() {}
// WatchPluginStatusRequest is the request for WatchPluginStatus.
type WatchPluginStatusRequest struct {
unknownFields []byte
}
func (x *WatchPluginStatusRequest) Reset() {
*x = WatchPluginStatusRequest{}
}
func (*WatchPluginStatusRequest) ProtoMessage() {}
// WatchPluginStatusResponse is one plugin status update from the host.
type WatchPluginStatusResponse struct {
unknownFields []byte
// InstanceKey is the instance key the host scheduler was configured with.
InstanceKey string `protobuf:"bytes,1,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
// Status is the scheduler's current plugin status snapshot.
Status *PluginStatusSnapshot `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
}
func (x *WatchPluginStatusResponse) Reset() {
*x = WatchPluginStatusResponse{}
}
func (*WatchPluginStatusResponse) ProtoMessage() {}
func (x *WatchPluginStatusResponse) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
func (x *WatchPluginStatusResponse) GetStatus() *PluginStatusSnapshot {
if x != nil {
return x.Status
}
return nil
}
// GetPluginInfoRequest is a request to return the information for the current plugin.
type GetPluginInfoRequest struct {
unknownFields []byte
}
func (x *GetPluginInfoRequest) Reset() {
*x = GetPluginInfoRequest{}
}
func (*GetPluginInfoRequest) ProtoMessage() {}
// GetPluginInfoResponse is the response to the GetPluginInfo request.
type GetPluginInfoResponse struct {
unknownFields []byte
// PluginId is the plugin identifier.
PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"pluginId,omitempty"`
// ManifestRef is the reference to the Manifest object.
ManifestRef *manifest.ManifestRef `protobuf:"bytes,2,opt,name=manifest_ref,json=manifestRef,proto3" json:"manifestRef,omitempty"`
// HostVolumeInfo is the optional information for the host Volume.
// The volume is exposed with a ProxyVolume when present.
HostVolumeInfo *volume.VolumeInfo `protobuf:"bytes,3,opt,name=host_volume_info,json=hostVolumeInfo,proto3" json:"hostVolumeInfo,omitempty"`
// Standalone reports that no PluginHost Resource graph is available.
Standalone bool `protobuf:"varint,4,opt,name=standalone,proto3" json:"standalone,omitempty"`
// HostStorageId is the Storage ID on the plugin host bus that this plugin
// instance allocates named volumes through. Empty selects the host default
// storage.
HostStorageId string `protobuf:"bytes,5,opt,name=host_storage_id,json=hostStorageId,proto3" json:"hostStorageId,omitempty"`
// Historical reports an immutable execution used for accepted-operation replay.
// The plugin serves handlers without publishing current UI or type registrations.
Historical bool `protobuf:"varint,6,opt,name=historical,proto3" json:"historical,omitempty"`
// Prepared requires private registrations until Activation.Activate is called.
Prepared bool `protobuf:"varint,7,opt,name=prepared,proto3" json:"prepared,omitempty"`
// InstanceKey is the logical installation binding, or empty for shared plugins.
// A Space uses its World engine ID. Physical worker generations do not change it.
InstanceKey string `protobuf:"bytes,8,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
}
func (x *GetPluginInfoResponse) Reset() {
*x = GetPluginInfoResponse{}
}
func (*GetPluginInfoResponse) ProtoMessage() {}
func (x *GetPluginInfoResponse) GetPluginId() string {
if x != nil {
return x.PluginId
}
return ""
}
func (x *GetPluginInfoResponse) GetManifestRef() *manifest.ManifestRef {
if x != nil {
return x.ManifestRef
}
return nil
}
func (x *GetPluginInfoResponse) GetHostVolumeInfo() *volume.VolumeInfo {
if x != nil {
return x.HostVolumeInfo
}
return nil
}
func (x *GetPluginInfoResponse) GetStandalone() bool {
if x != nil {
return x.Standalone
}
return false
}
func (x *GetPluginInfoResponse) GetHostStorageId() string {
if x != nil {
return x.HostStorageId
}
return ""
}
func (x *GetPluginInfoResponse) GetHistorical() bool {
if x != nil {
return x.Historical
}
return false
}
func (x *GetPluginInfoResponse) GetPrepared() bool {
if x != nil {
return x.Prepared
}
return false
}
func (x *GetPluginInfoResponse) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
// LoadPluginRequest is a request to load a plugin while the RPC is active.
type LoadPluginRequest struct {
unknownFields []byte
// PluginId is the plugin identifier to load.
PluginId string `protobuf:"bytes,1,opt,name=plugin_id,json=pluginId,proto3" json:"pluginId,omitempty"`
// InstanceKey is an optional key for instanced plugins.
// When non-empty, the plugin host uses (plugin_id, instance_key) as the
// composite deduplication key, allowing multiple independent instances of the
// same plugin to run concurrently in separate workers.
// When empty, behavior is unchanged: a single shared instance per plugin_id.
InstanceKey string `protobuf:"bytes,2,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
// Manifests selects the installation and its recovery artifacts, newest first.
Manifests []*manifest.ManifestRef `protobuf:"bytes,3,rep,name=manifests,proto3" json:"manifests,omitempty"`
// ManifestRoot loads an exact historical executable without current registrations.
ManifestRoot string `protobuf:"bytes,4,opt,name=manifest_root,json=manifestRoot,proto3" json:"manifestRoot,omitempty"`
}
func (x *LoadPluginRequest) Reset() {
*x = LoadPluginRequest{}
}
func (*LoadPluginRequest) ProtoMessage() {}
func (x *LoadPluginRequest) GetPluginId() string {
if x != nil {
return x.PluginId
}
return ""
}
func (x *LoadPluginRequest) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
func (x *LoadPluginRequest) GetManifests() []*manifest.ManifestRef {
if x != nil {
return x.Manifests
}
return nil
}
func (x *LoadPluginRequest) GetManifestRoot() string {
if x != nil {
return x.ManifestRoot
}
return ""
}
// LoadPluginResponse is a status response to a LoadPlugin request.
type LoadPluginResponse struct {
unknownFields []byte
// PluginStatus contains the current plugin status object.
PluginStatus *PluginStatus `protobuf:"bytes,1,opt,name=plugin_status,json=pluginStatus,proto3" json:"pluginStatus,omitempty"`
}
func (x *LoadPluginResponse) Reset() {
*x = LoadPluginResponse{}
}
func (*LoadPluginResponse) ProtoMessage() {}
func (x *LoadPluginResponse) GetPluginStatus() *PluginStatus {
if x != nil {
return x.PluginStatus
}
return nil
}
// PluginMeta is metadata embedded in a plugin entrypoint.
type PluginMeta struct {
unknownFields []byte
// ProjectId is the project identifier.
// Must be a valid-dns-label.
ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"projectId,omitempty"`
// PluginId is the plugin identifier.
// Must be a valid-dns-label.
PluginId string `protobuf:"bytes,2,opt,name=plugin_id,json=pluginId,proto3" json:"pluginId,omitempty"`
// PlatformId is the destination platform ID.
PlatformId string `protobuf:"bytes,3,opt,name=platform_id,json=platformId,proto3" json:"platformId,omitempty"`
// BuildType is the type of build this is.
BuildType string `protobuf:"bytes,4,opt,name=build_type,json=buildType,proto3" json:"buildType,omitempty"`
}
func (x *PluginMeta) Reset() {
*x = PluginMeta{}
}
func (*PluginMeta) ProtoMessage() {}
func (x *PluginMeta) GetProjectId() string {
if x != nil {
return x.ProjectId
}
return ""
}
func (x *PluginMeta) GetPluginId() string {
if x != nil {
return x.PluginId
}
return ""
}
func (x *PluginMeta) GetPlatformId() string {
if x != nil {
return x.PlatformId
}
return ""
}
func (x *PluginMeta) GetBuildType() string {
if x != nil {
return x.BuildType
}
return ""
}
// PluginStartInfo are details passed to the plugin by the plugin host in the environment.
type PluginStartInfo struct {
unknownFields []byte
// InstanceId is the plugin instance id.
InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instanceId,omitempty"`
// PluginId is the plugin identifier.
// Must be a valid-dns-label.
PluginId string `protobuf:"bytes,2,opt,name=plugin_id,json=pluginId,proto3" json:"pluginId,omitempty"`
// InstanceKey is the instance key from the LoadPlugin request.
// Empty for non-instanced (shared) plugins.
InstanceKey string `protobuf:"bytes,3,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
// ManifestRoot identifies the exact executable whose assets this worker imports.
// It is the base58-encoded manifest block hash, independent of the current revision.
ManifestRoot string `protobuf:"bytes,4,opt,name=manifest_root,json=manifestRoot,proto3" json:"manifestRoot,omitempty"`
}
func (x *PluginStartInfo) Reset() {
*x = PluginStartInfo{}
}
func (*PluginStartInfo) ProtoMessage() {}
func (x *PluginStartInfo) GetInstanceId() string {
if x != nil {
return x.InstanceId
}
return ""
}
func (x *PluginStartInfo) GetPluginId() string {
if x != nil {
return x.PluginId
}
return ""
}
func (x *PluginStartInfo) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
func (x *PluginStartInfo) GetManifestRoot() string {
if x != nil {
return x.ManifestRoot
}
return ""
}
// PluginContextInfo contains information about the running plugin attached to
// the Context tree for access within controllers running on the plugin bus.
type PluginContextInfo struct {
unknownFields []byte
// PluginMeta is the plugin metadata.
PluginMeta *PluginMeta `protobuf:"bytes,1,opt,name=plugin_meta,json=pluginMeta,proto3" json:"pluginMeta,omitempty"`
// InstanceKey identifies the plugin installation the host runs.
// Empty for a singleton plugin; a Space uses its World engine ID.
// State private to one installation is scoped by this key.
InstanceKey string `protobuf:"bytes,2,opt,name=instance_key,json=instanceKey,proto3" json:"instanceKey,omitempty"`
// ManifestRoot is the root of the manifest the plugin runs, which names the
// exact build of its files. Empty when the host did not report it.
ManifestRoot string `protobuf:"bytes,3,opt,name=manifest_root,json=manifestRoot,proto3" json:"manifestRoot,omitempty"`
}
func (x *PluginContextInfo) Reset() {
*x = PluginContextInfo{}
}
func (*PluginContextInfo) ProtoMessage() {}
func (x *PluginContextInfo) GetPluginMeta() *PluginMeta {
if x != nil {
return x.PluginMeta
}
return nil
}
func (x *PluginContextInfo) GetInstanceKey() string {
if x != nil {
return x.InstanceKey
}
return ""
}
func (x *PluginContextInfo) GetManifestRoot() string {
if x != nil {
return x.ManifestRoot
}
return ""
}
func (m *PluginStatus) CloneVT() *PluginStatus {
if m == nil {
return (*PluginStatus)(nil)
}
r := new(PluginStatus)
r.PluginId = m.PluginId
r.Running = m.Running
r.InstanceKey = m.InstanceKey
r.State = m.State
r.LastErrorMessage = m.LastErrorMessage
r.LastErrorAt = protobuf_go_lite.CloneVTValue(m.LastErrorAt)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PluginStatus) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PluginManifestRecoveryStatus) CloneVT() *PluginManifestRecoveryStatus {
if m == nil {
return (*PluginManifestRecoveryStatus)(nil)
}
r := new(PluginManifestRecoveryStatus)
r.PluginId = m.PluginId
r.InstanceKey = m.InstanceKey
r.ExecuteManifestRef = m.ExecuteManifestRef
r.DownloadManifestRef = m.DownloadManifestRef
r.SkippedCandidateCount = m.SkippedCandidateCount
r.SkippedCandidateSummary = m.SkippedCandidateSummary
r.IgnoredCandidateCount = m.IgnoredCandidateCount
r.IgnoredCandidateSummary = m.IgnoredCandidateSummary
r.QuarantinedCandidateCount = m.QuarantinedCandidateCount
r.QuarantinedCandidateSummary = m.QuarantinedCandidateSummary
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PluginManifestRecoveryStatus) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PluginStatusSnapshot) CloneVT() *PluginStatusSnapshot {
if m == nil {
return (*PluginStatusSnapshot)(nil)
}
r := new(PluginStatusSnapshot)
r.Plugins = protobuf_go_lite.CloneVTSlice(m.Plugins)
r.ManifestRecovery = protobuf_go_lite.CloneVTSlice(m.ManifestRecovery)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PluginStatusSnapshot) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *CheckActivationRequest) CloneVT() *CheckActivationRequest {
if m == nil {
return (*CheckActivationRequest)(nil)
}
r := new(CheckActivationRequest)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *CheckActivationRequest) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *CheckActivationResponse) CloneVT() *CheckActivationResponse {
if m == nil {
return (*CheckActivationResponse)(nil)
}
r := new(CheckActivationResponse)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *CheckActivationResponse) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *ActivatePluginRequest) CloneVT() *ActivatePluginRequest {
if m == nil {
return (*ActivatePluginRequest)(nil)
}
r := new(ActivatePluginRequest)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *ActivatePluginRequest) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *ActivatePluginResponse) CloneVT() *ActivatePluginResponse {
if m == nil {
return (*ActivatePluginResponse)(nil)
}
r := new(ActivatePluginResponse)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *ActivatePluginResponse) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PrepareUpdateRequest) CloneVT() *PrepareUpdateRequest {
if m == nil {
return (*PrepareUpdateRequest)(nil)
}
r := new(PrepareUpdateRequest)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PrepareUpdateRequest) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PrepareUpdateResponse) CloneVT() *PrepareUpdateResponse {
if m == nil {
return (*PrepareUpdateResponse)(nil)
}
r := new(PrepareUpdateResponse)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PrepareUpdateResponse) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *WatchPluginStatusRequest) CloneVT() *WatchPluginStatusRequest {
if m == nil {
return (*WatchPluginStatusRequest)(nil)
}
r := new(WatchPluginStatusRequest)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *WatchPluginStatusRequest) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *WatchPluginStatusResponse) CloneVT() *WatchPluginStatusResponse {
if m == nil {
return (*WatchPluginStatusResponse)(nil)
}
r := new(WatchPluginStatusResponse)
r.InstanceKey = m.InstanceKey
r.Status = protobuf_go_lite.CloneVTValue(m.Status)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *WatchPluginStatusResponse) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *GetPluginInfoRequest) CloneVT() *GetPluginInfoRequest {
if m == nil {
return (*GetPluginInfoRequest)(nil)
}
r := new(GetPluginInfoRequest)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *GetPluginInfoRequest) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *GetPluginInfoResponse) CloneVT() *GetPluginInfoResponse {
if m == nil {
return (*GetPluginInfoResponse)(nil)
}
r := new(GetPluginInfoResponse)
r.PluginId = m.PluginId
r.Standalone = m.Standalone
r.HostStorageId = m.HostStorageId
r.Historical = m.Historical
r.Prepared = m.Prepared
r.InstanceKey = m.InstanceKey
r.ManifestRef = protobuf_go_lite.CloneVTValue(m.ManifestRef)
r.HostVolumeInfo = protobuf_go_lite.CloneVTValue(m.HostVolumeInfo)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *GetPluginInfoResponse) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *LoadPluginRequest) CloneVT() *LoadPluginRequest {
if m == nil {
return (*LoadPluginRequest)(nil)
}
r := new(LoadPluginRequest)
r.PluginId = m.PluginId
r.InstanceKey = m.InstanceKey
r.ManifestRoot = m.ManifestRoot
r.Manifests = protobuf_go_lite.CloneVTSlice(m.Manifests)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *LoadPluginRequest) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *LoadPluginResponse) CloneVT() *LoadPluginResponse {
if m == nil {
return (*LoadPluginResponse)(nil)
}
r := new(LoadPluginResponse)
r.PluginStatus = protobuf_go_lite.CloneVTValue(m.PluginStatus)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *LoadPluginResponse) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PluginMeta) CloneVT() *PluginMeta {
if m == nil {
return (*PluginMeta)(nil)
}
r := new(PluginMeta)
r.ProjectId = m.ProjectId
r.PluginId = m.PluginId
r.PlatformId = m.PlatformId
r.BuildType = m.BuildType
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PluginMeta) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PluginStartInfo) CloneVT() *PluginStartInfo {
if m == nil {
return (*PluginStartInfo)(nil)
}
r := new(PluginStartInfo)
r.InstanceId = m.InstanceId
r.PluginId = m.PluginId
r.InstanceKey = m.InstanceKey
r.ManifestRoot = m.ManifestRoot
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PluginStartInfo) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (m *PluginContextInfo) CloneVT() *PluginContextInfo {
if m == nil {
return (*PluginContextInfo)(nil)
}
r := new(PluginContextInfo)
r.InstanceKey = m.InstanceKey
r.ManifestRoot = m.ManifestRoot
r.PluginMeta = protobuf_go_lite.CloneVTValue(m.PluginMeta)
if len(m.unknownFields) > 0 {
r.unknownFields = slices.Clone(m.unknownFields)
}
return r
}
func (m *PluginContextInfo) CloneMessageVT() protobuf_go_lite.CloneMessage {
return m.CloneVT()
}
func (this *PluginStatus) EqualVT(that *PluginStatus) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.PluginId != that.PluginId {
return false
}
if this.Running != that.Running {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
if this.State != that.State {
return false
}
if this.LastErrorMessage != that.LastErrorMessage {
return false
}
if !protobuf_go_lite.IsEqualVT(this.LastErrorAt, that.LastErrorAt) {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PluginStatus) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PluginStatus)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PluginManifestRecoveryStatus) EqualVT(that *PluginManifestRecoveryStatus) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.PluginId != that.PluginId {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
if this.ExecuteManifestRef != that.ExecuteManifestRef {
return false
}
if this.DownloadManifestRef != that.DownloadManifestRef {
return false
}
if this.SkippedCandidateCount != that.SkippedCandidateCount {
return false
}
if this.SkippedCandidateSummary != that.SkippedCandidateSummary {
return false
}
if this.IgnoredCandidateCount != that.IgnoredCandidateCount {
return false
}
if this.IgnoredCandidateSummary != that.IgnoredCandidateSummary {
return false
}
if this.QuarantinedCandidateCount != that.QuarantinedCandidateCount {
return false
}
if this.QuarantinedCandidateSummary != that.QuarantinedCandidateSummary {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PluginManifestRecoveryStatus) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PluginManifestRecoveryStatus)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PluginStatusSnapshot) EqualVT(that *PluginStatusSnapshot) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if !protobuf_go_lite.EqualVTSliceImplicit(this.Plugins, that.Plugins, func() *PluginStatus { return &PluginStatus{} }) {
return false
}
if !protobuf_go_lite.EqualVTSliceImplicit(this.ManifestRecovery, that.ManifestRecovery, func() *PluginManifestRecoveryStatus { return &PluginManifestRecoveryStatus{} }) {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PluginStatusSnapshot) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PluginStatusSnapshot)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *CheckActivationRequest) EqualVT(that *CheckActivationRequest) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *CheckActivationRequest) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*CheckActivationRequest)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *CheckActivationResponse) EqualVT(that *CheckActivationResponse) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *CheckActivationResponse) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*CheckActivationResponse)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *ActivatePluginRequest) EqualVT(that *ActivatePluginRequest) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *ActivatePluginRequest) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*ActivatePluginRequest)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *ActivatePluginResponse) EqualVT(that *ActivatePluginResponse) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *ActivatePluginResponse) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*ActivatePluginResponse)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PrepareUpdateRequest) EqualVT(that *PrepareUpdateRequest) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PrepareUpdateRequest) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PrepareUpdateRequest)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PrepareUpdateResponse) EqualVT(that *PrepareUpdateResponse) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PrepareUpdateResponse) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PrepareUpdateResponse)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *WatchPluginStatusRequest) EqualVT(that *WatchPluginStatusRequest) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *WatchPluginStatusRequest) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*WatchPluginStatusRequest)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *WatchPluginStatusResponse) EqualVT(that *WatchPluginStatusResponse) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
if !protobuf_go_lite.IsEqualVT(this.Status, that.Status) {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *WatchPluginStatusResponse) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*WatchPluginStatusResponse)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *GetPluginInfoRequest) EqualVT(that *GetPluginInfoRequest) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *GetPluginInfoRequest) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*GetPluginInfoRequest)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *GetPluginInfoResponse) EqualVT(that *GetPluginInfoResponse) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.PluginId != that.PluginId {
return false
}
if !protobuf_go_lite.IsEqualVT(this.ManifestRef, that.ManifestRef) {
return false
}
if !protobuf_go_lite.IsEqualVT(this.HostVolumeInfo, that.HostVolumeInfo) {
return false
}
if this.Standalone != that.Standalone {
return false
}
if this.HostStorageId != that.HostStorageId {
return false
}
if this.Historical != that.Historical {
return false
}
if this.Prepared != that.Prepared {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *GetPluginInfoResponse) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*GetPluginInfoResponse)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *LoadPluginRequest) EqualVT(that *LoadPluginRequest) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.PluginId != that.PluginId {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
if !protobuf_go_lite.EqualVTSliceImplicit(this.Manifests, that.Manifests, func() *manifest.ManifestRef { return &manifest.ManifestRef{} }) {
return false
}
if this.ManifestRoot != that.ManifestRoot {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *LoadPluginRequest) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*LoadPluginRequest)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *LoadPluginResponse) EqualVT(that *LoadPluginResponse) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if !protobuf_go_lite.IsEqualVT(this.PluginStatus, that.PluginStatus) {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *LoadPluginResponse) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*LoadPluginResponse)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PluginMeta) EqualVT(that *PluginMeta) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.ProjectId != that.ProjectId {
return false
}
if this.PluginId != that.PluginId {
return false
}
if this.PlatformId != that.PlatformId {
return false
}
if this.BuildType != that.BuildType {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PluginMeta) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PluginMeta)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PluginStartInfo) EqualVT(that *PluginStartInfo) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if this.InstanceId != that.InstanceId {
return false
}
if this.PluginId != that.PluginId {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
if this.ManifestRoot != that.ManifestRoot {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PluginStartInfo) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PluginStartInfo)
if !ok {
return false
}
return this.EqualVT(that)
}
func (this *PluginContextInfo) EqualVT(that *PluginContextInfo) bool {
if this == that {
return true
} else if this == nil || that == nil {
return false
}
if !protobuf_go_lite.IsEqualVT(this.PluginMeta, that.PluginMeta) {
return false
}
if this.InstanceKey != that.InstanceKey {
return false
}
if this.ManifestRoot != that.ManifestRoot {
return false
}
return string(this.unknownFields) == string(that.unknownFields)
}
func (this *PluginContextInfo) EqualMessageVT(thatMsg any) bool {
that, ok := thatMsg.(*PluginContextInfo)
if !ok {
return false
}
return this.EqualVT(that)
}
// MarshalProtoJSON marshals the PluginState to JSON.
func (x PluginState) MarshalProtoJSON(s *json.MarshalState) {
s.WriteEnum(int32(x), PluginState_name)
}
// MarshalText marshals the PluginState to text.
func (x PluginState) MarshalText() ([]byte, error) {
return []byte(json.GetEnumString(int32(x), PluginState_name)), nil
}
// MarshalJSON marshals the PluginState to JSON.
func (x PluginState) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginState from JSON.
func (x *PluginState) UnmarshalProtoJSON(s *json.UnmarshalState) {
v := s.ReadEnum(PluginState_value)
if err := s.Err(); err != nil {
s.SetErrorf("could not read PluginState enum: %v", err)
return
}
*x = PluginState(v)
}
// UnmarshalText unmarshals the PluginState from text.
func (x *PluginState) UnmarshalText(b []byte) error {
i, err := json.ParseEnumString(string(b), PluginState_value)
if err != nil {
return err
}
*x = PluginState(i)
return nil
}
// UnmarshalJSON unmarshals the PluginState from JSON.
func (x *PluginState) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PluginStatus message to JSON.
func (x *PluginStatus) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.PluginId != "" || s.HasField("pluginId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginId")
s.WriteString(x.PluginId)
}
if x.Running || s.HasField("running") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("running")
s.WriteBool(x.Running)
}
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
if x.State != 0 || s.HasField("state") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("state")
x.State.MarshalProtoJSON(s)
}
if x.LastErrorMessage != "" || s.HasField("lastErrorMessage") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("lastErrorMessage")
s.WriteString(x.LastErrorMessage)
}
if x.LastErrorAt != nil || s.HasField("lastErrorAt") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("lastErrorAt")
x.LastErrorAt.MarshalProtoJSON(s.WithField("lastErrorAt"))
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the PluginStatus to JSON.
func (x *PluginStatus) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginStatus message from JSON.
func (x *PluginStatus) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugin_id", "pluginId":
s.AddField("plugin_id")
x.PluginId = s.ReadString()
case "running":
s.AddField("running")
x.Running = s.ReadBool()
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
case "state":
s.AddField("state")
x.State.UnmarshalProtoJSON(s)
case "last_error_message", "lastErrorMessage":
s.AddField("last_error_message")
x.LastErrorMessage = s.ReadString()
case "last_error_at", "lastErrorAt":
if s.ReadNil() {
x.LastErrorAt = nil
return
}
x.LastErrorAt = ×tamppb.Timestamp{}
x.LastErrorAt.UnmarshalProtoJSON(s.WithField("last_error_at", true))
}
})
}
// UnmarshalJSON unmarshals the PluginStatus from JSON.
func (x *PluginStatus) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PluginManifestRecoveryStatus message to JSON.
func (x *PluginManifestRecoveryStatus) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.PluginId != "" || s.HasField("pluginId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginId")
s.WriteString(x.PluginId)
}
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
if x.ExecuteManifestRef != "" || s.HasField("executeManifestRef") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("executeManifestRef")
s.WriteString(x.ExecuteManifestRef)
}
if x.DownloadManifestRef != "" || s.HasField("downloadManifestRef") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("downloadManifestRef")
s.WriteString(x.DownloadManifestRef)
}
if x.SkippedCandidateCount != 0 || s.HasField("skippedCandidateCount") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("skippedCandidateCount")
s.WriteUint32(x.SkippedCandidateCount)
}
if x.SkippedCandidateSummary != "" || s.HasField("skippedCandidateSummary") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("skippedCandidateSummary")
s.WriteString(x.SkippedCandidateSummary)
}
if x.IgnoredCandidateCount != 0 || s.HasField("ignoredCandidateCount") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("ignoredCandidateCount")
s.WriteUint32(x.IgnoredCandidateCount)
}
if x.IgnoredCandidateSummary != "" || s.HasField("ignoredCandidateSummary") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("ignoredCandidateSummary")
s.WriteString(x.IgnoredCandidateSummary)
}
if x.QuarantinedCandidateCount != 0 || s.HasField("quarantinedCandidateCount") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("quarantinedCandidateCount")
s.WriteUint32(x.QuarantinedCandidateCount)
}
if x.QuarantinedCandidateSummary != "" || s.HasField("quarantinedCandidateSummary") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("quarantinedCandidateSummary")
s.WriteString(x.QuarantinedCandidateSummary)
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the PluginManifestRecoveryStatus to JSON.
func (x *PluginManifestRecoveryStatus) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginManifestRecoveryStatus message from JSON.
func (x *PluginManifestRecoveryStatus) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugin_id", "pluginId":
s.AddField("plugin_id")
x.PluginId = s.ReadString()
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
case "execute_manifest_ref", "executeManifestRef":
s.AddField("execute_manifest_ref")
x.ExecuteManifestRef = s.ReadString()
case "download_manifest_ref", "downloadManifestRef":
s.AddField("download_manifest_ref")
x.DownloadManifestRef = s.ReadString()
case "skipped_candidate_count", "skippedCandidateCount":
s.AddField("skipped_candidate_count")
x.SkippedCandidateCount = s.ReadUint32()
case "skipped_candidate_summary", "skippedCandidateSummary":
s.AddField("skipped_candidate_summary")
x.SkippedCandidateSummary = s.ReadString()
case "ignored_candidate_count", "ignoredCandidateCount":
s.AddField("ignored_candidate_count")
x.IgnoredCandidateCount = s.ReadUint32()
case "ignored_candidate_summary", "ignoredCandidateSummary":
s.AddField("ignored_candidate_summary")
x.IgnoredCandidateSummary = s.ReadString()
case "quarantined_candidate_count", "quarantinedCandidateCount":
s.AddField("quarantined_candidate_count")
x.QuarantinedCandidateCount = s.ReadUint32()
case "quarantined_candidate_summary", "quarantinedCandidateSummary":
s.AddField("quarantined_candidate_summary")
x.QuarantinedCandidateSummary = s.ReadString()
}
})
}
// UnmarshalJSON unmarshals the PluginManifestRecoveryStatus from JSON.
func (x *PluginManifestRecoveryStatus) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PluginStatusSnapshot message to JSON.
func (x *PluginStatusSnapshot) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if len(x.Plugins) > 0 || s.HasField("plugins") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("plugins")
s.WriteArrayStart()
var wroteElement bool
for _, element := range x.Plugins {
s.WriteMoreIf(&wroteElement)
element.MarshalProtoJSON(s.WithField("plugins"))
}
s.WriteArrayEnd()
}
if len(x.ManifestRecovery) > 0 || s.HasField("manifestRecovery") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("manifestRecovery")
s.WriteArrayStart()
var wroteElement bool
for _, element := range x.ManifestRecovery {
s.WriteMoreIf(&wroteElement)
element.MarshalProtoJSON(s.WithField("manifestRecovery"))
}
s.WriteArrayEnd()
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the PluginStatusSnapshot to JSON.
func (x *PluginStatusSnapshot) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginStatusSnapshot message from JSON.
func (x *PluginStatusSnapshot) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugins":
s.AddField("plugins")
if s.ReadNil() {
x.Plugins = nil
return
}
s.ReadArray(func() {
if s.ReadNil() {
x.Plugins = append(x.Plugins, nil)
return
}
v := &PluginStatus{}
v.UnmarshalProtoJSON(s.WithField("plugins", false))
if s.Err() != nil {
return
}
x.Plugins = append(x.Plugins, v)
})
case "manifest_recovery", "manifestRecovery":
s.AddField("manifest_recovery")
if s.ReadNil() {
x.ManifestRecovery = nil
return
}
s.ReadArray(func() {
if s.ReadNil() {
x.ManifestRecovery = append(x.ManifestRecovery, nil)
return
}
v := &PluginManifestRecoveryStatus{}
v.UnmarshalProtoJSON(s.WithField("manifest_recovery", false))
if s.Err() != nil {
return
}
x.ManifestRecovery = append(x.ManifestRecovery, v)
})
}
})
}
// UnmarshalJSON unmarshals the PluginStatusSnapshot from JSON.
func (x *PluginStatusSnapshot) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the CheckActivationRequest message to JSON.
func (x *CheckActivationRequest) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the CheckActivationRequest to JSON.
func (x *CheckActivationRequest) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the CheckActivationRequest message from JSON.
func (x *CheckActivationRequest) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the CheckActivationRequest from JSON.
func (x *CheckActivationRequest) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the CheckActivationResponse message to JSON.
func (x *CheckActivationResponse) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the CheckActivationResponse to JSON.
func (x *CheckActivationResponse) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the CheckActivationResponse message from JSON.
func (x *CheckActivationResponse) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the CheckActivationResponse from JSON.
func (x *CheckActivationResponse) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the ActivatePluginRequest message to JSON.
func (x *ActivatePluginRequest) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the ActivatePluginRequest to JSON.
func (x *ActivatePluginRequest) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the ActivatePluginRequest message from JSON.
func (x *ActivatePluginRequest) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the ActivatePluginRequest from JSON.
func (x *ActivatePluginRequest) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the ActivatePluginResponse message to JSON.
func (x *ActivatePluginResponse) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the ActivatePluginResponse to JSON.
func (x *ActivatePluginResponse) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the ActivatePluginResponse message from JSON.
func (x *ActivatePluginResponse) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the ActivatePluginResponse from JSON.
func (x *ActivatePluginResponse) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PrepareUpdateRequest message to JSON.
func (x *PrepareUpdateRequest) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the PrepareUpdateRequest to JSON.
func (x *PrepareUpdateRequest) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PrepareUpdateRequest message from JSON.
func (x *PrepareUpdateRequest) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the PrepareUpdateRequest from JSON.
func (x *PrepareUpdateRequest) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PrepareUpdateResponse message to JSON.
func (x *PrepareUpdateResponse) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the PrepareUpdateResponse to JSON.
func (x *PrepareUpdateResponse) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PrepareUpdateResponse message from JSON.
func (x *PrepareUpdateResponse) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the PrepareUpdateResponse from JSON.
func (x *PrepareUpdateResponse) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the WatchPluginStatusRequest message to JSON.
func (x *WatchPluginStatusRequest) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the WatchPluginStatusRequest to JSON.
func (x *WatchPluginStatusRequest) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the WatchPluginStatusRequest message from JSON.
func (x *WatchPluginStatusRequest) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the WatchPluginStatusRequest from JSON.
func (x *WatchPluginStatusRequest) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the WatchPluginStatusResponse message to JSON.
func (x *WatchPluginStatusResponse) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
if x.Status != nil || s.HasField("status") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("status")
x.Status.MarshalProtoJSON(s.WithField("status"))
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the WatchPluginStatusResponse to JSON.
func (x *WatchPluginStatusResponse) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the WatchPluginStatusResponse message from JSON.
func (x *WatchPluginStatusResponse) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
case "status":
if s.ReadNil() {
x.Status = nil
return
}
x.Status = &PluginStatusSnapshot{}
x.Status.UnmarshalProtoJSON(s.WithField("status", true))
}
})
}
// UnmarshalJSON unmarshals the WatchPluginStatusResponse from JSON.
func (x *WatchPluginStatusResponse) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the GetPluginInfoRequest message to JSON.
func (x *GetPluginInfoRequest) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
s.WriteObjectEnd()
}
// MarshalJSON marshals the GetPluginInfoRequest to JSON.
func (x *GetPluginInfoRequest) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the GetPluginInfoRequest message from JSON.
func (x *GetPluginInfoRequest) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
// no fields
})
}
// UnmarshalJSON unmarshals the GetPluginInfoRequest from JSON.
func (x *GetPluginInfoRequest) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the GetPluginInfoResponse message to JSON.
func (x *GetPluginInfoResponse) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.PluginId != "" || s.HasField("pluginId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginId")
s.WriteString(x.PluginId)
}
if x.ManifestRef != nil || s.HasField("manifestRef") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("manifestRef")
x.ManifestRef.MarshalProtoJSON(s.WithField("manifestRef"))
}
if x.HostVolumeInfo != nil || s.HasField("hostVolumeInfo") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("hostVolumeInfo")
x.HostVolumeInfo.MarshalProtoJSON(s.WithField("hostVolumeInfo"))
}
if x.Standalone || s.HasField("standalone") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("standalone")
s.WriteBool(x.Standalone)
}
if x.HostStorageId != "" || s.HasField("hostStorageId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("hostStorageId")
s.WriteString(x.HostStorageId)
}
if x.Historical || s.HasField("historical") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("historical")
s.WriteBool(x.Historical)
}
if x.Prepared || s.HasField("prepared") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("prepared")
s.WriteBool(x.Prepared)
}
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the GetPluginInfoResponse to JSON.
func (x *GetPluginInfoResponse) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the GetPluginInfoResponse message from JSON.
func (x *GetPluginInfoResponse) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugin_id", "pluginId":
s.AddField("plugin_id")
x.PluginId = s.ReadString()
case "manifest_ref", "manifestRef":
if s.ReadNil() {
x.ManifestRef = nil
return
}
x.ManifestRef = &manifest.ManifestRef{}
x.ManifestRef.UnmarshalProtoJSON(s.WithField("manifest_ref", true))
case "host_volume_info", "hostVolumeInfo":
if s.ReadNil() {
x.HostVolumeInfo = nil
return
}
x.HostVolumeInfo = &volume.VolumeInfo{}
x.HostVolumeInfo.UnmarshalProtoJSON(s.WithField("host_volume_info", true))
case "standalone":
s.AddField("standalone")
x.Standalone = s.ReadBool()
case "host_storage_id", "hostStorageId":
s.AddField("host_storage_id")
x.HostStorageId = s.ReadString()
case "historical":
s.AddField("historical")
x.Historical = s.ReadBool()
case "prepared":
s.AddField("prepared")
x.Prepared = s.ReadBool()
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
}
})
}
// UnmarshalJSON unmarshals the GetPluginInfoResponse from JSON.
func (x *GetPluginInfoResponse) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the LoadPluginRequest message to JSON.
func (x *LoadPluginRequest) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.PluginId != "" || s.HasField("pluginId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginId")
s.WriteString(x.PluginId)
}
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
if len(x.Manifests) > 0 || s.HasField("manifests") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("manifests")
s.WriteArrayStart()
var wroteElement bool
for _, element := range x.Manifests {
s.WriteMoreIf(&wroteElement)
element.MarshalProtoJSON(s.WithField("manifests"))
}
s.WriteArrayEnd()
}
if x.ManifestRoot != "" || s.HasField("manifestRoot") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("manifestRoot")
s.WriteString(x.ManifestRoot)
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the LoadPluginRequest to JSON.
func (x *LoadPluginRequest) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the LoadPluginRequest message from JSON.
func (x *LoadPluginRequest) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugin_id", "pluginId":
s.AddField("plugin_id")
x.PluginId = s.ReadString()
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
case "manifests":
s.AddField("manifests")
if s.ReadNil() {
x.Manifests = nil
return
}
s.ReadArray(func() {
if s.ReadNil() {
x.Manifests = append(x.Manifests, nil)
return
}
v := &manifest.ManifestRef{}
v.UnmarshalProtoJSON(s.WithField("manifests", false))
if s.Err() != nil {
return
}
x.Manifests = append(x.Manifests, v)
})
case "manifest_root", "manifestRoot":
s.AddField("manifest_root")
x.ManifestRoot = s.ReadString()
}
})
}
// UnmarshalJSON unmarshals the LoadPluginRequest from JSON.
func (x *LoadPluginRequest) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the LoadPluginResponse message to JSON.
func (x *LoadPluginResponse) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.PluginStatus != nil || s.HasField("pluginStatus") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginStatus")
x.PluginStatus.MarshalProtoJSON(s.WithField("pluginStatus"))
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the LoadPluginResponse to JSON.
func (x *LoadPluginResponse) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the LoadPluginResponse message from JSON.
func (x *LoadPluginResponse) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugin_status", "pluginStatus":
if s.ReadNil() {
x.PluginStatus = nil
return
}
x.PluginStatus = &PluginStatus{}
x.PluginStatus.UnmarshalProtoJSON(s.WithField("plugin_status", true))
}
})
}
// UnmarshalJSON unmarshals the LoadPluginResponse from JSON.
func (x *LoadPluginResponse) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PluginMeta message to JSON.
func (x *PluginMeta) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.ProjectId != "" || s.HasField("projectId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("projectId")
s.WriteString(x.ProjectId)
}
if x.PluginId != "" || s.HasField("pluginId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginId")
s.WriteString(x.PluginId)
}
if x.PlatformId != "" || s.HasField("platformId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("platformId")
s.WriteString(x.PlatformId)
}
if x.BuildType != "" || s.HasField("buildType") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("buildType")
s.WriteString(x.BuildType)
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the PluginMeta to JSON.
func (x *PluginMeta) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginMeta message from JSON.
func (x *PluginMeta) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "project_id", "projectId":
s.AddField("project_id")
x.ProjectId = s.ReadString()
case "plugin_id", "pluginId":
s.AddField("plugin_id")
x.PluginId = s.ReadString()
case "platform_id", "platformId":
s.AddField("platform_id")
x.PlatformId = s.ReadString()
case "build_type", "buildType":
s.AddField("build_type")
x.BuildType = s.ReadString()
}
})
}
// UnmarshalJSON unmarshals the PluginMeta from JSON.
func (x *PluginMeta) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PluginStartInfo message to JSON.
func (x *PluginStartInfo) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.InstanceId != "" || s.HasField("instanceId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceId")
s.WriteString(x.InstanceId)
}
if x.PluginId != "" || s.HasField("pluginId") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginId")
s.WriteString(x.PluginId)
}
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
if x.ManifestRoot != "" || s.HasField("manifestRoot") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("manifestRoot")
s.WriteString(x.ManifestRoot)
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the PluginStartInfo to JSON.
func (x *PluginStartInfo) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginStartInfo message from JSON.
func (x *PluginStartInfo) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "instance_id", "instanceId":
s.AddField("instance_id")
x.InstanceId = s.ReadString()
case "plugin_id", "pluginId":
s.AddField("plugin_id")
x.PluginId = s.ReadString()
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
case "manifest_root", "manifestRoot":
s.AddField("manifest_root")
x.ManifestRoot = s.ReadString()
}
})
}
// UnmarshalJSON unmarshals the PluginStartInfo from JSON.
func (x *PluginStartInfo) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
// MarshalProtoJSON marshals the PluginContextInfo message to JSON.
func (x *PluginContextInfo) MarshalProtoJSON(s *json.MarshalState) {
if x == nil {
s.WriteNil()
return
}
s.WriteObjectStart()
var wroteField bool
if x.PluginMeta != nil || s.HasField("pluginMeta") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("pluginMeta")
x.PluginMeta.MarshalProtoJSON(s.WithField("pluginMeta"))
}
if x.InstanceKey != "" || s.HasField("instanceKey") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("instanceKey")
s.WriteString(x.InstanceKey)
}
if x.ManifestRoot != "" || s.HasField("manifestRoot") {
s.WriteMoreIf(&wroteField)
s.WriteObjectField("manifestRoot")
s.WriteString(x.ManifestRoot)
}
s.WriteObjectEnd()
}
// MarshalJSON marshals the PluginContextInfo to JSON.
func (x *PluginContextInfo) MarshalJSON() ([]byte, error) {
return json.DefaultMarshalerConfig.Marshal(x)
}
// UnmarshalProtoJSON unmarshals the PluginContextInfo message from JSON.
func (x *PluginContextInfo) UnmarshalProtoJSON(s *json.UnmarshalState) {
if s.ReadNil() {
return
}
s.ReadObject(func(key string) {
switch key {
default:
s.Skip() // ignore unknown field
case "plugin_meta", "pluginMeta":
if s.ReadNil() {
x.PluginMeta = nil
return
}
x.PluginMeta = &PluginMeta{}
x.PluginMeta.UnmarshalProtoJSON(s.WithField("plugin_meta", true))
case "instance_key", "instanceKey":
s.AddField("instance_key")
x.InstanceKey = s.ReadString()
case "manifest_root", "manifestRoot":
s.AddField("manifest_root")
x.ManifestRoot = s.ReadString()
}
})
}
// UnmarshalJSON unmarshals the PluginContextInfo from JSON.
func (x *PluginContextInfo) UnmarshalJSON(b []byte) error {
return json.DefaultUnmarshalerConfig.Unmarshal(b, x)
}
func (m *PluginStatus) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginStatus) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if m.LastErrorAt != nil {
size, err := m.LastErrorAt.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0x32
}
if len(m.LastErrorMessage) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.LastErrorMessage)
i--
dAtA[i] = 0x2a
}
if m.State != 0 {
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(m.State))
i--
dAtA[i] = 0x20
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0x1a
}
if m.Running {
i = protobuf_go_lite.EncodeBool(dAtA, i, m.Running)
i--
dAtA[i] = 0x10
}
if len(m.PluginId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PluginId)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginManifestRecoveryStatus) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginManifestRecoveryStatus) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginManifestRecoveryStatus) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.QuarantinedCandidateSummary) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.QuarantinedCandidateSummary)
i--
dAtA[i] = 0x52
}
if m.QuarantinedCandidateCount != 0 {
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(m.QuarantinedCandidateCount))
i--
dAtA[i] = 0x48
}
if len(m.IgnoredCandidateSummary) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.IgnoredCandidateSummary)
i--
dAtA[i] = 0x42
}
if m.IgnoredCandidateCount != 0 {
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(m.IgnoredCandidateCount))
i--
dAtA[i] = 0x38
}
if len(m.SkippedCandidateSummary) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.SkippedCandidateSummary)
i--
dAtA[i] = 0x32
}
if m.SkippedCandidateCount != 0 {
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(m.SkippedCandidateCount))
i--
dAtA[i] = 0x28
}
if len(m.DownloadManifestRef) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.DownloadManifestRef)
i--
dAtA[i] = 0x22
}
if len(m.ExecuteManifestRef) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.ExecuteManifestRef)
i--
dAtA[i] = 0x1a
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0x12
}
if len(m.PluginId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PluginId)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginStatusSnapshot) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginStatusSnapshot) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginStatusSnapshot) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.ManifestRecovery) > 0 {
for iNdEx := len(m.ManifestRecovery) - 1; iNdEx >= 0; iNdEx-- {
size, err := m.ManifestRecovery[iNdEx].MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0x12
}
}
if len(m.Plugins) > 0 {
for iNdEx := len(m.Plugins) - 1; iNdEx >= 0; iNdEx-- {
size, err := m.Plugins[iNdEx].MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0xa
}
}
return len(dAtA) - i, nil
}
func (m *CheckActivationRequest) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *CheckActivationRequest) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *CheckActivationRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *CheckActivationResponse) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *CheckActivationResponse) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *CheckActivationResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *ActivatePluginRequest) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *ActivatePluginRequest) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *ActivatePluginRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *ActivatePluginResponse) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *ActivatePluginResponse) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *ActivatePluginResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *PrepareUpdateRequest) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PrepareUpdateRequest) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PrepareUpdateRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *PrepareUpdateResponse) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PrepareUpdateResponse) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PrepareUpdateResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *WatchPluginStatusRequest) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *WatchPluginStatusRequest) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *WatchPluginStatusRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *WatchPluginStatusResponse) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *WatchPluginStatusResponse) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *WatchPluginStatusResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if m.Status != nil {
size, err := m.Status.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0x12
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *GetPluginInfoRequest) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetPluginInfoRequest) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *GetPluginInfoRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
return len(dAtA) - i, nil
}
func (m *GetPluginInfoResponse) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *GetPluginInfoResponse) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *GetPluginInfoResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0x42
}
if m.Prepared {
i = protobuf_go_lite.EncodeBool(dAtA, i, m.Prepared)
i--
dAtA[i] = 0x38
}
if m.Historical {
i = protobuf_go_lite.EncodeBool(dAtA, i, m.Historical)
i--
dAtA[i] = 0x30
}
if len(m.HostStorageId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.HostStorageId)
i--
dAtA[i] = 0x2a
}
if m.Standalone {
i = protobuf_go_lite.EncodeBool(dAtA, i, m.Standalone)
i--
dAtA[i] = 0x20
}
if m.HostVolumeInfo != nil {
size, err := m.HostVolumeInfo.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0x1a
}
if m.ManifestRef != nil {
size, err := m.ManifestRef.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0x12
}
if len(m.PluginId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PluginId)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *LoadPluginRequest) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *LoadPluginRequest) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *LoadPluginRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.ManifestRoot) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.ManifestRoot)
i--
dAtA[i] = 0x22
}
if len(m.Manifests) > 0 {
for iNdEx := len(m.Manifests) - 1; iNdEx >= 0; iNdEx-- {
size, err := m.Manifests[iNdEx].MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0x1a
}
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0x12
}
if len(m.PluginId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PluginId)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *LoadPluginResponse) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *LoadPluginResponse) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *LoadPluginResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if m.PluginStatus != nil {
size, err := m.PluginStatus.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginMeta) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginMeta) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginMeta) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.BuildType) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.BuildType)
i--
dAtA[i] = 0x22
}
if len(m.PlatformId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PlatformId)
i--
dAtA[i] = 0x1a
}
if len(m.PluginId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PluginId)
i--
dAtA[i] = 0x12
}
if len(m.ProjectId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.ProjectId)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginStartInfo) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginStartInfo) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginStartInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.ManifestRoot) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.ManifestRoot)
i--
dAtA[i] = 0x22
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0x1a
}
if len(m.PluginId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.PluginId)
i--
dAtA[i] = 0x12
}
if len(m.InstanceId) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceId)
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginContextInfo) MarshalVT() (dAtA []byte, err error) {
if m == nil {
return nil, nil
}
size := m.SizeVT()
dAtA = make([]byte, size)
n, err := m.MarshalToSizedBufferVT(dAtA[:size])
if err != nil {
return nil, err
}
return dAtA[:n], nil
}
func (m *PluginContextInfo) MarshalToVT(dAtA []byte) (int, error) {
size := m.SizeVT()
return m.MarshalToSizedBufferVT(dAtA[:size])
}
func (m *PluginContextInfo) MarshalToSizedBufferVT(dAtA []byte) (int, error) {
if m == nil {
return 0, nil
}
i := len(dAtA)
_ = i
var l int
_ = l
if m.unknownFields != nil {
i = protobuf_go_lite.EncodeRawBytes(dAtA, i, m.unknownFields)
}
if len(m.ManifestRoot) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.ManifestRoot)
i--
dAtA[i] = 0x1a
}
if len(m.InstanceKey) > 0 {
i = protobuf_go_lite.EncodeString(dAtA, i, m.InstanceKey)
i--
dAtA[i] = 0x12
}
if m.PluginMeta != nil {
size, err := m.PluginMeta.MarshalToSizedBufferVT(dAtA[:i])
if err != nil {
return 0, err
}
i -= size
i = protobuf_go_lite.EncodeVarint(dAtA, i, uint64(size))
i--
dAtA[i] = 0xa
}
return len(dAtA) - i, nil
}
func (m *PluginStatus) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PluginId)
n += protobuf_go_lite.SizeBoolNonZero(1, m.Running)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
n += protobuf_go_lite.SizeVarintNonZero(1, m.State)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.LastErrorMessage)
if m.LastErrorAt != nil {
l = m.LastErrorAt.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += len(m.unknownFields)
return n
}
func (m *PluginManifestRecoveryStatus) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PluginId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.ExecuteManifestRef)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.DownloadManifestRef)
n += protobuf_go_lite.SizeVarintNonZero(1, m.SkippedCandidateCount)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.SkippedCandidateSummary)
n += protobuf_go_lite.SizeVarintNonZero(1, m.IgnoredCandidateCount)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.IgnoredCandidateSummary)
n += protobuf_go_lite.SizeVarintNonZero(1, m.QuarantinedCandidateCount)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.QuarantinedCandidateSummary)
n += len(m.unknownFields)
return n
}
func (m *PluginStatusSnapshot) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
for _, e := range m.Plugins {
l = e.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
for _, e := range m.ManifestRecovery {
l = e.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += len(m.unknownFields)
return n
}
func (m *CheckActivationRequest) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *CheckActivationResponse) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *ActivatePluginRequest) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *ActivatePluginResponse) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *PrepareUpdateRequest) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *PrepareUpdateResponse) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *WatchPluginStatusRequest) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *WatchPluginStatusResponse) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
if m.Status != nil {
l = m.Status.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += len(m.unknownFields)
return n
}
func (m *GetPluginInfoRequest) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += len(m.unknownFields)
return n
}
func (m *GetPluginInfoResponse) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PluginId)
if m.ManifestRef != nil {
l = m.ManifestRef.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
if m.HostVolumeInfo != nil {
l = m.HostVolumeInfo.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += protobuf_go_lite.SizeBoolNonZero(1, m.Standalone)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.HostStorageId)
n += protobuf_go_lite.SizeBoolNonZero(1, m.Historical)
n += protobuf_go_lite.SizeBoolNonZero(1, m.Prepared)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
n += len(m.unknownFields)
return n
}
func (m *LoadPluginRequest) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PluginId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
for _, e := range m.Manifests {
l = e.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += protobuf_go_lite.SizeStringNonEmpty(1, m.ManifestRoot)
n += len(m.unknownFields)
return n
}
func (m *LoadPluginResponse) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.PluginStatus != nil {
l = m.PluginStatus.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += len(m.unknownFields)
return n
}
func (m *PluginMeta) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.ProjectId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PluginId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PlatformId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.BuildType)
n += len(m.unknownFields)
return n
}
func (m *PluginStartInfo) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.PluginId)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.ManifestRoot)
n += len(m.unknownFields)
return n
}
func (m *PluginContextInfo) SizeVT() (n int) {
if m == nil {
return 0
}
var l int
_ = l
if m.PluginMeta != nil {
l = m.PluginMeta.SizeVT()
n += protobuf_go_lite.SizeMessage(1, l)
}
n += protobuf_go_lite.SizeStringNonEmpty(1, m.InstanceKey)
n += protobuf_go_lite.SizeStringNonEmpty(1, m.ManifestRoot)
n += len(m.unknownFields)
return n
}
func (x PluginState) MarshalProtoText() string {
return x.String()
}
func (x *PluginStatus) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "PluginStatus")
if x.PluginId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_id")
protobuf_go_lite.TextWriteString(&sb, x.PluginId)
}
if x.Running != false {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "running")
protobuf_go_lite.TextWriteBool(&sb, x.Running)
}
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
if x.State != 0 {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "state")
protobuf_go_lite.TextWriteStringer(&sb, PluginState(x.State))
}
if x.LastErrorMessage != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "last_error_message")
protobuf_go_lite.TextWriteString(&sb, x.LastErrorMessage)
}
if x.LastErrorAt != nil {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "last_error_at")
protobuf_go_lite.TextWriteTextMarshaler(&sb, x.LastErrorAt)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PluginStatus) String() string {
return x.MarshalProtoText()
}
func (x *PluginManifestRecoveryStatus) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "PluginManifestRecoveryStatus")
if x.PluginId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_id")
protobuf_go_lite.TextWriteString(&sb, x.PluginId)
}
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
if x.ExecuteManifestRef != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "execute_manifest_ref")
protobuf_go_lite.TextWriteString(&sb, x.ExecuteManifestRef)
}
if x.DownloadManifestRef != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "download_manifest_ref")
protobuf_go_lite.TextWriteString(&sb, x.DownloadManifestRef)
}
if x.SkippedCandidateCount != 0 {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "skipped_candidate_count")
protobuf_go_lite.TextWriteUint(&sb, x.SkippedCandidateCount)
}
if x.SkippedCandidateSummary != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "skipped_candidate_summary")
protobuf_go_lite.TextWriteString(&sb, x.SkippedCandidateSummary)
}
if x.IgnoredCandidateCount != 0 {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "ignored_candidate_count")
protobuf_go_lite.TextWriteUint(&sb, x.IgnoredCandidateCount)
}
if x.IgnoredCandidateSummary != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "ignored_candidate_summary")
protobuf_go_lite.TextWriteString(&sb, x.IgnoredCandidateSummary)
}
if x.QuarantinedCandidateCount != 0 {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "quarantined_candidate_count")
protobuf_go_lite.TextWriteUint(&sb, x.QuarantinedCandidateCount)
}
if x.QuarantinedCandidateSummary != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "quarantined_candidate_summary")
protobuf_go_lite.TextWriteString(&sb, x.QuarantinedCandidateSummary)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PluginManifestRecoveryStatus) String() string {
return x.MarshalProtoText()
}
func (x *PluginStatusSnapshot) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "PluginStatusSnapshot")
if len(x.Plugins) > 0 {
protobuf_go_lite.TextWriteListStart(&sb, initialLen, "plugins")
for i, v := range x.Plugins {
protobuf_go_lite.TextWriteListSeparator(&sb, i)
if v == nil {
protobuf_go_lite.TextWriteTextMarshaler(&sb, &PluginStatus{})
} else {
protobuf_go_lite.TextWriteTextMarshaler(&sb, v)
}
}
protobuf_go_lite.TextWriteListEnd(&sb)
}
if len(x.ManifestRecovery) > 0 {
protobuf_go_lite.TextWriteListStart(&sb, initialLen, "manifest_recovery")
for i, v := range x.ManifestRecovery {
protobuf_go_lite.TextWriteListSeparator(&sb, i)
if v == nil {
protobuf_go_lite.TextWriteTextMarshaler(&sb, &PluginManifestRecoveryStatus{})
} else {
protobuf_go_lite.TextWriteTextMarshaler(&sb, v)
}
}
protobuf_go_lite.TextWriteListEnd(&sb)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PluginStatusSnapshot) String() string {
return x.MarshalProtoText()
}
func (x *CheckActivationRequest) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "CheckActivationRequest")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *CheckActivationRequest) String() string {
return x.MarshalProtoText()
}
func (x *CheckActivationResponse) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "CheckActivationResponse")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *CheckActivationResponse) String() string {
return x.MarshalProtoText()
}
func (x *ActivatePluginRequest) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "ActivatePluginRequest")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *ActivatePluginRequest) String() string {
return x.MarshalProtoText()
}
func (x *ActivatePluginResponse) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "ActivatePluginResponse")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *ActivatePluginResponse) String() string {
return x.MarshalProtoText()
}
func (x *PrepareUpdateRequest) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "PrepareUpdateRequest")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PrepareUpdateRequest) String() string {
return x.MarshalProtoText()
}
func (x *PrepareUpdateResponse) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "PrepareUpdateResponse")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PrepareUpdateResponse) String() string {
return x.MarshalProtoText()
}
func (x *WatchPluginStatusRequest) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "WatchPluginStatusRequest")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *WatchPluginStatusRequest) String() string {
return x.MarshalProtoText()
}
func (x *WatchPluginStatusResponse) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "WatchPluginStatusResponse")
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
if x.Status != nil {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "status")
protobuf_go_lite.TextWriteTextMarshaler(&sb, x.Status)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *WatchPluginStatusResponse) String() string {
return x.MarshalProtoText()
}
func (x *GetPluginInfoRequest) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
protobuf_go_lite.TextStartMessage(&sb, "GetPluginInfoRequest")
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *GetPluginInfoRequest) String() string {
return x.MarshalProtoText()
}
func (x *GetPluginInfoResponse) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "GetPluginInfoResponse")
if x.PluginId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_id")
protobuf_go_lite.TextWriteString(&sb, x.PluginId)
}
if x.ManifestRef != nil {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "manifest_ref")
protobuf_go_lite.TextWriteTextMarshaler(&sb, x.ManifestRef)
}
if x.HostVolumeInfo != nil {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "host_volume_info")
protobuf_go_lite.TextWriteTextMarshaler(&sb, x.HostVolumeInfo)
}
if x.Standalone != false {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "standalone")
protobuf_go_lite.TextWriteBool(&sb, x.Standalone)
}
if x.HostStorageId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "host_storage_id")
protobuf_go_lite.TextWriteString(&sb, x.HostStorageId)
}
if x.Historical != false {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "historical")
protobuf_go_lite.TextWriteBool(&sb, x.Historical)
}
if x.Prepared != false {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "prepared")
protobuf_go_lite.TextWriteBool(&sb, x.Prepared)
}
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *GetPluginInfoResponse) String() string {
return x.MarshalProtoText()
}
func (x *LoadPluginRequest) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "LoadPluginRequest")
if x.PluginId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_id")
protobuf_go_lite.TextWriteString(&sb, x.PluginId)
}
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
if len(x.Manifests) > 0 {
protobuf_go_lite.TextWriteListStart(&sb, initialLen, "manifests")
for i, v := range x.Manifests {
protobuf_go_lite.TextWriteListSeparator(&sb, i)
if v == nil {
protobuf_go_lite.TextWriteTextMarshaler(&sb, &manifest.ManifestRef{})
} else {
protobuf_go_lite.TextWriteTextMarshaler(&sb, v)
}
}
protobuf_go_lite.TextWriteListEnd(&sb)
}
if x.ManifestRoot != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "manifest_root")
protobuf_go_lite.TextWriteString(&sb, x.ManifestRoot)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *LoadPluginRequest) String() string {
return x.MarshalProtoText()
}
func (x *LoadPluginResponse) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "LoadPluginResponse")
if x.PluginStatus != nil {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_status")
protobuf_go_lite.TextWriteTextMarshaler(&sb, x.PluginStatus)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *LoadPluginResponse) String() string {
return x.MarshalProtoText()
}
func (x *PluginMeta) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "PluginMeta")
if x.ProjectId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "project_id")
protobuf_go_lite.TextWriteString(&sb, x.ProjectId)
}
if x.PluginId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_id")
protobuf_go_lite.TextWriteString(&sb, x.PluginId)
}
if x.PlatformId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "platform_id")
protobuf_go_lite.TextWriteString(&sb, x.PlatformId)
}
if x.BuildType != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "build_type")
protobuf_go_lite.TextWriteString(&sb, x.BuildType)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PluginMeta) String() string {
return x.MarshalProtoText()
}
func (x *PluginStartInfo) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "PluginStartInfo")
if x.InstanceId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_id")
protobuf_go_lite.TextWriteString(&sb, x.InstanceId)
}
if x.PluginId != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_id")
protobuf_go_lite.TextWriteString(&sb, x.PluginId)
}
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
if x.ManifestRoot != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "manifest_root")
protobuf_go_lite.TextWriteString(&sb, x.ManifestRoot)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PluginStartInfo) String() string {
return x.MarshalProtoText()
}
func (x *PluginContextInfo) MarshalProtoText() string {
var sb protobuf_go_lite.TextBuilder
initialLen := protobuf_go_lite.TextStartMessage(&sb, "PluginContextInfo")
if x.PluginMeta != nil {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "plugin_meta")
protobuf_go_lite.TextWriteTextMarshaler(&sb, x.PluginMeta)
}
if x.InstanceKey != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "instance_key")
protobuf_go_lite.TextWriteString(&sb, x.InstanceKey)
}
if x.ManifestRoot != "" {
protobuf_go_lite.TextWriteFieldPrefix(&sb, initialLen, "manifest_root")
protobuf_go_lite.TextWriteString(&sb, x.ManifestRoot)
}
return protobuf_go_lite.TextFinishMessage(&sb)
}
func (x *PluginContextInfo) String() string {
return x.MarshalProtoText()
}
func (m *PluginStatus) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginStatus: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginStatus: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PluginId = v
case 2:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Running", wireType)
}
var v bool
v, iNdEx, err = protobuf_go_lite.DecodeVarintBool(dAtA, iNdEx)
if err != nil {
return err
}
m.Running = bool(v)
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field State", wireType)
}
m.State = 0
var _v uint64
_v, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
m.State = PluginState(_v)
if err != nil {
return err
}
case 5:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field LastErrorMessage", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.LastErrorMessage = v
case 6:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field LastErrorAt", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
if m.LastErrorAt == nil {
m.LastErrorAt = ×tamppb.Timestamp{}
}
if err := m.LastErrorAt.UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PluginManifestRecoveryStatus) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginManifestRecoveryStatus: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginManifestRecoveryStatus: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PluginId = v
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ExecuteManifestRef", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.ExecuteManifestRef = v
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field DownloadManifestRef", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.DownloadManifestRef = v
case 5:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field SkippedCandidateCount", wireType)
}
m.SkippedCandidateCount = 0
m.SkippedCandidateCount, iNdEx, err = protobuf_go_lite.DecodeVarintUint32(dAtA, iNdEx)
if err != nil {
return err
}
case 6:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field SkippedCandidateSummary", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.SkippedCandidateSummary = v
case 7:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field IgnoredCandidateCount", wireType)
}
m.IgnoredCandidateCount = 0
m.IgnoredCandidateCount, iNdEx, err = protobuf_go_lite.DecodeVarintUint32(dAtA, iNdEx)
if err != nil {
return err
}
case 8:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field IgnoredCandidateSummary", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.IgnoredCandidateSummary = v
case 9:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field QuarantinedCandidateCount", wireType)
}
m.QuarantinedCandidateCount = 0
m.QuarantinedCandidateCount, iNdEx, err = protobuf_go_lite.DecodeVarintUint32(dAtA, iNdEx)
if err != nil {
return err
}
case 10:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field QuarantinedCandidateSummary", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.QuarantinedCandidateSummary = v
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PluginStatusSnapshot) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginStatusSnapshot: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginStatusSnapshot: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Plugins", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
m.Plugins = append(m.Plugins, &PluginStatus{})
if err := m.Plugins[len(m.Plugins)-1].UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ManifestRecovery", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
m.ManifestRecovery = append(m.ManifestRecovery, &PluginManifestRecoveryStatus{})
if err := m.ManifestRecovery[len(m.ManifestRecovery)-1].UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *CheckActivationRequest) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: CheckActivationRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: CheckActivationRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *CheckActivationResponse) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: CheckActivationResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: CheckActivationResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *ActivatePluginRequest) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: ActivatePluginRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: ActivatePluginRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *ActivatePluginResponse) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: ActivatePluginResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: ActivatePluginResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PrepareUpdateRequest) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PrepareUpdateRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PrepareUpdateRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PrepareUpdateResponse) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PrepareUpdateResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PrepareUpdateResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *WatchPluginStatusRequest) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: WatchPluginStatusRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: WatchPluginStatusRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *WatchPluginStatusResponse) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: WatchPluginStatusResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: WatchPluginStatusResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Status", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
if m.Status == nil {
m.Status = &PluginStatusSnapshot{}
}
if err := m.Status.UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetPluginInfoRequest) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetPluginInfoRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetPluginInfoRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *GetPluginInfoResponse) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: GetPluginInfoResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: GetPluginInfoResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PluginId = v
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ManifestRef", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
if m.ManifestRef == nil {
m.ManifestRef = &manifest.ManifestRef{}
}
if err := m.ManifestRef.UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field HostVolumeInfo", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
if m.HostVolumeInfo == nil {
m.HostVolumeInfo = &volume.VolumeInfo{}
}
if err := m.HostVolumeInfo.UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 4:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Standalone", wireType)
}
var v bool
v, iNdEx, err = protobuf_go_lite.DecodeVarintBool(dAtA, iNdEx)
if err != nil {
return err
}
m.Standalone = bool(v)
case 5:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field HostStorageId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.HostStorageId = v
case 6:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Historical", wireType)
}
var v bool
v, iNdEx, err = protobuf_go_lite.DecodeVarintBool(dAtA, iNdEx)
if err != nil {
return err
}
m.Historical = bool(v)
case 7:
if wireType != 0 {
return fmt.Errorf("proto: wrong wireType = %d for field Prepared", wireType)
}
var v bool
v, iNdEx, err = protobuf_go_lite.DecodeVarintBool(dAtA, iNdEx)
if err != nil {
return err
}
m.Prepared = bool(v)
case 8:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *LoadPluginRequest) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: LoadPluginRequest: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: LoadPluginRequest: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PluginId = v
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field Manifests", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
m.Manifests = append(m.Manifests, &manifest.ManifestRef{})
if err := m.Manifests[len(m.Manifests)-1].UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ManifestRoot", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.ManifestRoot = v
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *LoadPluginResponse) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: LoadPluginResponse: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: LoadPluginResponse: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginStatus", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
if m.PluginStatus == nil {
m.PluginStatus = &PluginStatus{}
}
if err := m.PluginStatus.UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PluginMeta) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginMeta: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginMeta: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ProjectId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.ProjectId = v
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PluginId = v
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PlatformId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PlatformId = v
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field BuildType", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.BuildType = v
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PluginStartInfo) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginStartInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginStartInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceId = v
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginId", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.PluginId = v
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
case 4:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ManifestRoot", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.ManifestRoot = v
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}
func (m *PluginContextInfo) UnmarshalVT(dAtA []byte) error {
l := len(dAtA)
iNdEx := 0
var err error
for iNdEx < l {
preIndex := iNdEx
var wire uint64
wire, iNdEx, err = protobuf_go_lite.DecodeVarint(dAtA, iNdEx)
if err != nil {
return err
}
fieldNum := int32(wire >> 3)
wireType := int(wire & 0x7)
if wireType == 4 {
return fmt.Errorf("proto: PluginContextInfo: wiretype end group for non-group")
}
if fieldNum <= 0 {
return fmt.Errorf("proto: PluginContextInfo: illegal tag %d (wire type %d)", fieldNum, wire)
}
switch fieldNum {
case 1:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field PluginMeta", wireType)
}
msgStart, postIndex, err := protobuf_go_lite.DecodeLengthDelimited(dAtA, iNdEx)
if err != nil {
return err
}
if m.PluginMeta == nil {
m.PluginMeta = &PluginMeta{}
}
if err := m.PluginMeta.UnmarshalVT(dAtA[msgStart:postIndex]); err != nil {
return err
}
iNdEx = postIndex
case 2:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field InstanceKey", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.InstanceKey = v
case 3:
if wireType != 2 {
return fmt.Errorf("proto: wrong wireType = %d for field ManifestRoot", wireType)
}
var v string
v, iNdEx, err = protobuf_go_lite.DecodeString(dAtA, iNdEx)
if err != nil {
return err
}
m.ManifestRoot = v
default:
iNdEx = preIndex
skippy, err := protobuf_go_lite.Skip(dAtA[iNdEx:])
if err != nil {
return err
}
if (skippy < 0) || (iNdEx+skippy) < 0 {
return protobuf_go_lite.ErrInvalidLength
}
if (iNdEx + skippy) > l {
return io.ErrUnexpectedEOF
}
m.unknownFields = append(m.unknownFields, dAtA[iNdEx:iNdEx+skippy]...)
iNdEx += skippy
}
}
if iNdEx > l {
return io.ErrUnexpectedEOF
}
return nil
}