// 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 }