Documentation ¶
Index ¶
- Variables
- type Action
- func (*Action) Descriptor() ([]byte, []int)deprecated
- func (x *Action) GetContent() []byte
- func (x *Action) GetEntityName() string
- func (x *Action) GetEntityType() string
- func (x *Action) GetId() string
- func (x *Action) GetMessageType() string
- func (x *Action) GetMessageVersion() string
- func (x *Action) GetNodeId() string
- func (x *Action) GetOrganizationName() string
- func (x *Action) GetParentName() string
- func (x *Action) GetParentType() string
- func (x *Action) GetRecordedAt() string
- func (x *Action) GetRemoteHostname() string
- func (x *Action) GetRemoteRequestId() string
- func (x *Action) GetRequestId() string
- func (x *Action) GetRequestorName() string
- func (x *Action) GetRequestorType() string
- func (x *Action) GetRevisionId() string
- func (x *Action) GetRunId() string
- func (x *Action) GetServiceHostname() string
- func (x *Action) GetTask() string
- func (x *Action) GetUserAgent() string
- func (*Action) ProtoMessage()
- func (x *Action) ProtoReflect() protoreflect.Message
- func (x *Action) Reset()
- func (x *Action) String() string
- type Delete
- func (*Delete) Descriptor() ([]byte, []int)deprecated
- func (x *Delete) GetId() string
- func (x *Delete) GetNodeId() string
- func (x *Delete) GetNodeName() string
- func (x *Delete) GetOrganizationName() string
- func (x *Delete) GetRemoteHostname() string
- func (x *Delete) GetServiceHostname() string
- func (*Delete) ProtoMessage()
- func (x *Delete) ProtoReflect() protoreflect.Message
- func (x *Delete) Reset()
- func (x *Delete) String() string
- type DeleteMarkedNodes
- type Deprecation
- func (*Deprecation) Descriptor() ([]byte, []int)deprecated
- func (x *Deprecation) GetLocation() string
- func (x *Deprecation) GetMessage() string
- func (x *Deprecation) GetUrl() string
- func (*Deprecation) ProtoMessage()
- func (x *Deprecation) ProtoReflect() protoreflect.Message
- func (x *Deprecation) Reset()
- func (x *Deprecation) String() string
- type Description
- func (*Description) Descriptor() ([]byte, []int)deprecated
- func (x *Description) GetSections() []*structpb.Struct
- func (x *Description) GetTitle() string
- func (*Description) ProtoMessage()
- func (x *Description) ProtoReflect() protoreflect.Message
- func (x *Description) Reset()
- func (x *Description) String() string
- type Error
- func (*Error) Descriptor() ([]byte, []int)deprecated
- func (x *Error) GetBacktrace() []string
- func (x *Error) GetClass() string
- func (x *Error) GetDescription() *Description
- func (x *Error) GetMessage() string
- func (*Error) ProtoMessage()
- func (x *Error) ProtoReflect() protoreflect.Message
- func (x *Error) Reset()
- func (x *Error) String() string
- type ExpandedRunList
- func (*ExpandedRunList) Descriptor() ([]byte, []int)deprecated
- func (x *ExpandedRunList) GetId() string
- func (x *ExpandedRunList) GetRunList() []*RunList
- func (*ExpandedRunList) ProtoMessage()
- func (x *ExpandedRunList) ProtoReflect() protoreflect.Message
- func (x *ExpandedRunList) Reset()
- func (x *ExpandedRunList) String() string
- type GetStatusJobScheduler
- type Liveness
- func (*Liveness) Descriptor() ([]byte, []int)deprecated
- func (x *Liveness) GetChefServerFqdn() string
- func (x *Liveness) GetEntityUuid() string
- func (x *Liveness) GetEventType() string
- func (x *Liveness) GetMessageVersion() string
- func (x *Liveness) GetNodeName() string
- func (x *Liveness) GetOrganizationName() string
- func (x *Liveness) GetSource() string
- func (*Liveness) ProtoMessage()
- func (x *Liveness) ProtoReflect() protoreflect.Message
- func (x *Liveness) Reset()
- func (x *Liveness) String() string
- type MarkMissingNodesForDeletion
- type MarkNodesMissing
- type MultipleNodeDeleteRequest
- func (*MultipleNodeDeleteRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MultipleNodeDeleteRequest) GetNodeIds() []string
- func (*MultipleNodeDeleteRequest) ProtoMessage()
- func (x *MultipleNodeDeleteRequest) ProtoReflect() protoreflect.Message
- func (x *MultipleNodeDeleteRequest) Reset()
- func (x *MultipleNodeDeleteRequest) String() string
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetAfter() *structpb.Struct
- func (x *Resource) GetBefore() *structpb.Struct
- func (x *Resource) GetConditional() string
- func (x *Resource) GetCookbookName() string
- func (x *Resource) GetCookbookVersion() string
- func (x *Resource) GetDelta() string
- func (x *Resource) GetDuration() string
- func (x *Resource) GetError() *Error
- func (x *Resource) GetId() string
- func (x *Resource) GetIgnoreFailure() *structpb.Value
- func (x *Resource) GetName() string
- func (x *Resource) GetRecipeName() string
- func (x *Resource) GetResult() string
- func (x *Resource) GetStatus() string
- func (x *Resource) GetType() string
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- type Run
- func (*Run) Descriptor() ([]byte, []int)deprecated
- func (x *Run) GetChefServerFqdn() string
- func (x *Run) GetContent() []byte
- func (x *Run) GetDeprecations() []*Deprecation
- func (x *Run) GetEndTime() string
- func (x *Run) GetEntityUuid() string
- func (x *Run) GetError() *Error
- func (x *Run) GetExpandedRunList() *ExpandedRunList
- func (x *Run) GetId() string
- func (x *Run) GetMessageType() string
- func (x *Run) GetMessageVersion() string
- func (x *Run) GetNode() *structpb.Struct
- func (x *Run) GetNodeName() string
- func (x *Run) GetOrganizationName() string
- func (x *Run) GetPolicyGroup() string
- func (x *Run) GetPolicyName() string
- func (x *Run) GetResources() []*Resource
- func (x *Run) GetRunId() string
- func (x *Run) GetRunList() []string
- func (x *Run) GetSource() string
- func (x *Run) GetStartTime() string
- func (x *Run) GetStatus() string
- func (x *Run) GetTags() []string
- func (x *Run) GetTotalResourceCount() int32
- func (x *Run) GetUpdatedResourceCount() int32
- func (*Run) ProtoMessage()
- func (x *Run) ProtoReflect() protoreflect.Message
- func (x *Run) Reset()
- func (x *Run) String() string
- func (run *Run) ToJSONBytes() ([]byte, error)
- func (run *Run) ToJSONString() (string, error)
- type RunList
- func (*RunList) Descriptor() ([]byte, []int)deprecated
- func (x *RunList) GetChildren() []*RunList
- func (x *RunList) GetName() string
- func (x *RunList) GetSkipped() bool
- func (x *RunList) GetType() string
- func (x *RunList) GetVersion() string
- func (*RunList) ProtoMessage()
- func (x *RunList) ProtoReflect() protoreflect.Message
- func (x *RunList) Reset()
- func (x *RunList) String() string
- type SchedulerConfig
- func (*SchedulerConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SchedulerConfig) GetEvery() string
- func (x *SchedulerConfig) GetRunning() bool
- func (x *SchedulerConfig) GetThreshold() string
- func (*SchedulerConfig) ProtoMessage()
- func (x *SchedulerConfig) ProtoReflect() protoreflect.Message
- func (x *SchedulerConfig) Reset()
- func (x *SchedulerConfig) String() string
- type StartDeleteNodesScheduler
- type StartMissingNodesForDeletionScheduler
- func (*StartMissingNodesForDeletionScheduler) Descriptor() ([]byte, []int)deprecated
- func (*StartMissingNodesForDeletionScheduler) ProtoMessage()
- func (x *StartMissingNodesForDeletionScheduler) ProtoReflect() protoreflect.Message
- func (x *StartMissingNodesForDeletionScheduler) Reset()
- func (x *StartMissingNodesForDeletionScheduler) String() string
- type StartNodesMissingScheduler
- type StopDeleteNodesScheduler
- type StopMissingNodesForDeletionScheduler
- func (*StopMissingNodesForDeletionScheduler) Descriptor() ([]byte, []int)deprecated
- func (*StopMissingNodesForDeletionScheduler) ProtoMessage()
- func (x *StopMissingNodesForDeletionScheduler) ProtoReflect() protoreflect.Message
- func (x *StopMissingNodesForDeletionScheduler) Reset()
- func (x *StopMissingNodesForDeletionScheduler) String() string
- type StopNodesMissingScheduler
Constants ¶
This section is empty.
Variables ¶
var File_external_ingest_request_action_proto protoreflect.FileDescriptor
var File_external_ingest_request_chef_proto protoreflect.FileDescriptor
var File_external_ingest_request_job_scheduler_proto protoreflect.FileDescriptor
var File_external_ingest_request_liveness_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Action ¶
type Action struct { // ID of the action message itself Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` MessageType string `protobuf:"bytes,2,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` MessageVersion string `protobuf:"bytes,3,opt,name=message_version,json=messageVersion,proto3" json:"message_version,omitempty"` EntityName string `protobuf:"bytes,4,opt,name=entity_name,json=entityName,proto3" json:"entity_name,omitempty"` EntityType string `protobuf:"bytes,5,opt,name=entity_type,json=entityType,proto3" json:"entity_type,omitempty"` Task string `protobuf:"bytes,6,opt,name=task,proto3" json:"task,omitempty"` OrganizationName string `protobuf:"bytes,7,opt,name=organization_name,json=organizationName,proto3" json:"organization_name,omitempty"` RemoteHostname string `protobuf:"bytes,8,opt,name=remote_hostname,json=remoteHostname,proto3" json:"remote_hostname,omitempty"` RunId string `protobuf:"bytes,9,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` // This new field called 'content' is being used to send the entire raw JSON // message in bytes, this field is heavily used by the gateway for the DataCollector // Func Handler that will send the Action message to the (receiver) ingest-service // that will manually unmarshal the message from this field if it is provided. // The main purpose of this field it to improve the performance of ingestion when // the requests comes in REST/HTTP format. Content []byte `protobuf:"bytes,10,opt,name=content,proto3" json:"content,omitempty"` NodeId string `protobuf:"bytes,16,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Not available from Chef Server RecordedAt string `protobuf:"bytes,17,opt,name=recorded_at,json=recordedAt,proto3" json:"recorded_at,omitempty"` RemoteRequestId string `protobuf:"bytes,18,opt,name=remote_request_id,json=remoteRequestId,proto3" json:"remote_request_id,omitempty"` RequestId string `protobuf:"bytes,19,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` RequestorName string `protobuf:"bytes,20,opt,name=requestor_name,json=requestorName,proto3" json:"requestor_name,omitempty"` RequestorType string `protobuf:"bytes,21,opt,name=requestor_type,json=requestorType,proto3" json:"requestor_type,omitempty"` ServiceHostname string `protobuf:"bytes,22,opt,name=service_hostname,json=serviceHostname,proto3" json:"service_hostname,omitempty"` UserAgent string `protobuf:"bytes,23,opt,name=user_agent,json=userAgent,proto3" json:"user_agent,omitempty"` ParentType string `protobuf:"bytes,24,opt,name=parent_type,json=parentType,proto3" json:"parent_type,omitempty"` ParentName string `protobuf:"bytes,25,opt,name=parent_name,json=parentName,proto3" json:"parent_name,omitempty"` RevisionId string `protobuf:"bytes,27,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"` // contains filtered or unexported fields }
func (*Action) Descriptor
deprecated
func (*Action) GetContent ¶
func (*Action) GetEntityName ¶
func (*Action) GetEntityType ¶
func (*Action) GetMessageType ¶
func (*Action) GetMessageVersion ¶
func (*Action) GetOrganizationName ¶
func (*Action) GetParentName ¶
func (*Action) GetParentType ¶
func (*Action) GetRecordedAt ¶
func (*Action) GetRemoteHostname ¶
func (*Action) GetRemoteRequestId ¶
func (*Action) GetRequestId ¶
func (*Action) GetRequestorName ¶
func (*Action) GetRequestorType ¶
func (*Action) GetRevisionId ¶
func (*Action) GetServiceHostname ¶
func (*Action) GetUserAgent ¶
func (*Action) ProtoMessage ¶
func (*Action) ProtoMessage()
func (*Action) ProtoReflect ¶
func (x *Action) ProtoReflect() protoreflect.Message
type Delete ¶
type Delete struct { // ID of the action message itself Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` NodeName string `protobuf:"bytes,4,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` OrganizationName string `protobuf:"bytes,7,opt,name=organization_name,json=organizationName,proto3" json:"organization_name,omitempty"` RemoteHostname string `protobuf:"bytes,8,opt,name=remote_hostname,json=remoteHostname,proto3" json:"remote_hostname,omitempty"` ServiceHostname string `protobuf:"bytes,9,opt,name=service_hostname,json=serviceHostname,proto3" json:"service_hostname,omitempty"` NodeId string `protobuf:"bytes,16,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // Not available from Chef Server // contains filtered or unexported fields }
func (*Delete) Descriptor
deprecated
func (*Delete) GetNodeName ¶
func (*Delete) GetOrganizationName ¶
func (*Delete) GetRemoteHostname ¶
func (*Delete) GetServiceHostname ¶
func (*Delete) ProtoMessage ¶
func (*Delete) ProtoMessage()
func (*Delete) ProtoReflect ¶
func (x *Delete) ProtoReflect() protoreflect.Message
type DeleteMarkedNodes ¶
type DeleteMarkedNodes struct {
// contains filtered or unexported fields
}
DeleteNodesScheduler
func (*DeleteMarkedNodes) Descriptor
deprecated
func (*DeleteMarkedNodes) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMarkedNodes.ProtoReflect.Descriptor instead.
func (*DeleteMarkedNodes) ProtoMessage ¶
func (*DeleteMarkedNodes) ProtoMessage()
func (*DeleteMarkedNodes) ProtoReflect ¶
func (x *DeleteMarkedNodes) ProtoReflect() protoreflect.Message
func (*DeleteMarkedNodes) Reset ¶
func (x *DeleteMarkedNodes) Reset()
func (*DeleteMarkedNodes) String ¶
func (x *DeleteMarkedNodes) String() string
type Deprecation ¶
type Deprecation struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` Location string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"` // contains filtered or unexported fields }
func (*Deprecation) Descriptor
deprecated
func (*Deprecation) Descriptor() ([]byte, []int)
Deprecated: Use Deprecation.ProtoReflect.Descriptor instead.
func (*Deprecation) GetLocation ¶
func (x *Deprecation) GetLocation() string
func (*Deprecation) GetMessage ¶
func (x *Deprecation) GetMessage() string
func (*Deprecation) GetUrl ¶
func (x *Deprecation) GetUrl() string
func (*Deprecation) ProtoMessage ¶
func (*Deprecation) ProtoMessage()
func (*Deprecation) ProtoReflect ¶
func (x *Deprecation) ProtoReflect() protoreflect.Message
func (*Deprecation) Reset ¶
func (x *Deprecation) Reset()
func (*Deprecation) String ¶
func (x *Deprecation) String() string
type Description ¶
type Description struct { Title string `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"` Sections []*structpb.Struct `protobuf:"bytes,2,rep,name=sections,proto3" json:"sections,omitempty"` // contains filtered or unexported fields }
func (*Description) Descriptor
deprecated
func (*Description) Descriptor() ([]byte, []int)
Deprecated: Use Description.ProtoReflect.Descriptor instead.
func (*Description) GetSections ¶
func (x *Description) GetSections() []*structpb.Struct
func (*Description) GetTitle ¶
func (x *Description) GetTitle() string
func (*Description) ProtoMessage ¶
func (*Description) ProtoMessage()
func (*Description) ProtoReflect ¶
func (x *Description) ProtoReflect() protoreflect.Message
func (*Description) Reset ¶
func (x *Description) Reset()
func (*Description) String ¶
func (x *Description) String() string
type Error ¶
type Error struct { Class string `protobuf:"bytes,1,opt,name=class,proto3" json:"class,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` Backtrace []string `protobuf:"bytes,16,rep,name=backtrace,proto3" json:"backtrace,omitempty"` Description *Description `protobuf:"bytes,17,opt,name=description,proto3" json:"description,omitempty"` // contains filtered or unexported fields }
func (*Error) Descriptor
deprecated
func (*Error) GetBacktrace ¶
func (*Error) GetDescription ¶
func (x *Error) GetDescription() *Description
func (*Error) GetMessage ¶
func (*Error) ProtoMessage ¶
func (*Error) ProtoMessage()
func (*Error) ProtoReflect ¶
func (x *Error) ProtoReflect() protoreflect.Message
type ExpandedRunList ¶
type ExpandedRunList struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` RunList []*RunList `protobuf:"bytes,2,rep,name=run_list,json=runList,proto3" json:"run_list,omitempty"` // contains filtered or unexported fields }
func (*ExpandedRunList) Descriptor
deprecated
func (*ExpandedRunList) Descriptor() ([]byte, []int)
Deprecated: Use ExpandedRunList.ProtoReflect.Descriptor instead.
func (*ExpandedRunList) GetId ¶
func (x *ExpandedRunList) GetId() string
func (*ExpandedRunList) GetRunList ¶
func (x *ExpandedRunList) GetRunList() []*RunList
func (*ExpandedRunList) ProtoMessage ¶
func (*ExpandedRunList) ProtoMessage()
func (*ExpandedRunList) ProtoReflect ¶
func (x *ExpandedRunList) ProtoReflect() protoreflect.Message
func (*ExpandedRunList) Reset ¶
func (x *ExpandedRunList) Reset()
func (*ExpandedRunList) String ¶
func (x *ExpandedRunList) String() string
type GetStatusJobScheduler ¶
type GetStatusJobScheduler struct {
// contains filtered or unexported fields
}
func (*GetStatusJobScheduler) Descriptor
deprecated
func (*GetStatusJobScheduler) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusJobScheduler.ProtoReflect.Descriptor instead.
func (*GetStatusJobScheduler) ProtoMessage ¶
func (*GetStatusJobScheduler) ProtoMessage()
func (*GetStatusJobScheduler) ProtoReflect ¶
func (x *GetStatusJobScheduler) ProtoReflect() protoreflect.Message
func (*GetStatusJobScheduler) Reset ¶
func (x *GetStatusJobScheduler) Reset()
func (*GetStatusJobScheduler) String ¶
func (x *GetStatusJobScheduler) String() string
type Liveness ¶
type Liveness struct { EventType string `protobuf:"bytes,1,opt,name=event_type,json=eventType,proto3" json:"event_type,omitempty"` EntityUuid string `protobuf:"bytes,2,opt,name=entity_uuid,json=entityUuid,proto3" json:"entity_uuid,omitempty"` ChefServerFqdn string `protobuf:"bytes,3,opt,name=chef_server_fqdn,json=chefServerFqdn,proto3" json:"chef_server_fqdn,omitempty"` Source string `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"` MessageVersion string `protobuf:"bytes,5,opt,name=message_version,json=messageVersion,proto3" json:"message_version,omitempty"` OrganizationName string `protobuf:"bytes,6,opt,name=organization_name,json=organizationName,proto3" json:"organization_name,omitempty"` NodeName string `protobuf:"bytes,7,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` // contains filtered or unexported fields }
func (*Liveness) Descriptor
deprecated
func (*Liveness) GetChefServerFqdn ¶
func (*Liveness) GetEntityUuid ¶
func (*Liveness) GetEventType ¶
func (*Liveness) GetMessageVersion ¶
func (*Liveness) GetNodeName ¶
func (*Liveness) GetOrganizationName ¶
func (*Liveness) ProtoMessage ¶
func (*Liveness) ProtoMessage()
func (*Liveness) ProtoReflect ¶
func (x *Liveness) ProtoReflect() protoreflect.Message
type MarkMissingNodesForDeletion ¶
type MarkMissingNodesForDeletion struct {
// contains filtered or unexported fields
}
MissingNodesForDeletionScheduler
func (*MarkMissingNodesForDeletion) Descriptor
deprecated
func (*MarkMissingNodesForDeletion) Descriptor() ([]byte, []int)
Deprecated: Use MarkMissingNodesForDeletion.ProtoReflect.Descriptor instead.
func (*MarkMissingNodesForDeletion) ProtoMessage ¶
func (*MarkMissingNodesForDeletion) ProtoMessage()
func (*MarkMissingNodesForDeletion) ProtoReflect ¶
func (x *MarkMissingNodesForDeletion) ProtoReflect() protoreflect.Message
func (*MarkMissingNodesForDeletion) Reset ¶
func (x *MarkMissingNodesForDeletion) Reset()
func (*MarkMissingNodesForDeletion) String ¶
func (x *MarkMissingNodesForDeletion) String() string
type MarkNodesMissing ¶
type MarkNodesMissing struct {
// contains filtered or unexported fields
}
NodesMissingScheduler
func (*MarkNodesMissing) Descriptor
deprecated
func (*MarkNodesMissing) Descriptor() ([]byte, []int)
Deprecated: Use MarkNodesMissing.ProtoReflect.Descriptor instead.
func (*MarkNodesMissing) ProtoMessage ¶
func (*MarkNodesMissing) ProtoMessage()
func (*MarkNodesMissing) ProtoReflect ¶
func (x *MarkNodesMissing) ProtoReflect() protoreflect.Message
func (*MarkNodesMissing) Reset ¶
func (x *MarkNodesMissing) Reset()
func (*MarkNodesMissing) String ¶
func (x *MarkNodesMissing) String() string
type MultipleNodeDeleteRequest ¶
type MultipleNodeDeleteRequest struct { NodeIds []string `protobuf:"bytes,1,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"` // contains filtered or unexported fields }
func (*MultipleNodeDeleteRequest) Descriptor
deprecated
func (*MultipleNodeDeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use MultipleNodeDeleteRequest.ProtoReflect.Descriptor instead.
func (*MultipleNodeDeleteRequest) GetNodeIds ¶
func (x *MultipleNodeDeleteRequest) GetNodeIds() []string
func (*MultipleNodeDeleteRequest) ProtoMessage ¶
func (*MultipleNodeDeleteRequest) ProtoMessage()
func (*MultipleNodeDeleteRequest) ProtoReflect ¶
func (x *MultipleNodeDeleteRequest) ProtoReflect() protoreflect.Message
func (*MultipleNodeDeleteRequest) Reset ¶
func (x *MultipleNodeDeleteRequest) Reset()
func (*MultipleNodeDeleteRequest) String ¶
func (x *MultipleNodeDeleteRequest) String() string
type Resource ¶
type Resource struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Id string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"` After *structpb.Struct `protobuf:"bytes,4,opt,name=after,proto3" json:"after,omitempty"` //TODO: Define fields? Before *structpb.Struct `protobuf:"bytes,5,opt,name=before,proto3" json:"before,omitempty"` //TODO: Define fields? Duration string `protobuf:"bytes,6,opt,name=duration,proto3" json:"duration,omitempty"` Delta string `protobuf:"bytes,7,opt,name=delta,proto3" json:"delta,omitempty"` CookbookName string `protobuf:"bytes,8,opt,name=cookbook_name,json=cookbookName,proto3" json:"cookbook_name,omitempty"` CookbookVersion string `protobuf:"bytes,9,opt,name=cookbook_version,json=cookbookVersion,proto3" json:"cookbook_version,omitempty"` Status string `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"` RecipeName string `protobuf:"bytes,12,opt,name=recipe_name,json=recipeName,proto3" json:"recipe_name,omitempty"` IgnoreFailure *structpb.Value `protobuf:"bytes,13,opt,name=ignore_failure,json=ignoreFailure,proto3" json:"ignore_failure,omitempty"` Conditional string `protobuf:"bytes,16,opt,name=conditional,proto3" json:"conditional,omitempty"` Result string `protobuf:"bytes,17,opt,name=result,proto3" json:"result,omitempty"` Error *Error `protobuf:"bytes,18,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
func (*Resource) Descriptor
deprecated
func (*Resource) GetConditional ¶
func (*Resource) GetCookbookName ¶
func (*Resource) GetCookbookVersion ¶
func (*Resource) GetDuration ¶
func (*Resource) GetIgnoreFailure ¶
func (*Resource) GetRecipeName ¶
func (*Resource) ProtoMessage ¶
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶
func (x *Resource) ProtoReflect() protoreflect.Message
type Run ¶
type Run struct { // 1 through 15 are for frequently occuring fields // Reserving for shared fields between run_start and run_converge mesages. Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // message Id RunId string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"` EntityUuid string `protobuf:"bytes,3,opt,name=entity_uuid,json=entityUuid,proto3" json:"entity_uuid,omitempty"` MessageVersion string `protobuf:"bytes,4,opt,name=message_version,json=messageVersion,proto3" json:"message_version,omitempty"` MessageType string `protobuf:"bytes,5,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` NodeName string `protobuf:"bytes,6,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"` OrganizationName string `protobuf:"bytes,7,opt,name=organization_name,json=organizationName,proto3" json:"organization_name,omitempty"` StartTime string `protobuf:"bytes,8,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"` ChefServerFqdn string `protobuf:"bytes,9,opt,name=chef_server_fqdn,json=chefServerFqdn,proto3" json:"chef_server_fqdn,omitempty"` // This new field called 'content' is being used to send the entire raw JSON // message in bytes, this field is heavily used by the gateway for the DataCollector // Func Handler that will send the Run message to the (receiver) ingest-service // that will manually unmarshal the message from this field if it is provided. // The main purpose of this field it to improve the performance of ingestion when // the requests comes in REST/HTTP format. Content []byte `protobuf:"bytes,10,opt,name=content,proto3" json:"content,omitempty"` EndTime string `protobuf:"bytes,16,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"` Status string `protobuf:"bytes,17,opt,name=status,proto3" json:"status,omitempty"` TotalResourceCount int32 `protobuf:"varint,18,opt,name=total_resource_count,json=totalResourceCount,proto3" json:"total_resource_count,omitempty"` UpdatedResourceCount int32 `protobuf:"varint,19,opt,name=updated_resource_count,json=updatedResourceCount,proto3" json:"updated_resource_count,omitempty"` Source string `protobuf:"bytes,20,opt,name=source,proto3" json:"source,omitempty"` ExpandedRunList *ExpandedRunList `protobuf:"bytes,21,opt,name=expanded_run_list,json=expandedRunList,proto3" json:"expanded_run_list,omitempty"` Resources []*Resource `protobuf:"bytes,22,rep,name=resources,proto3" json:"resources,omitempty"` RunList []string `protobuf:"bytes,23,rep,name=run_list,json=runList,proto3" json:"run_list,omitempty"` Node *structpb.Struct `protobuf:"bytes,24,opt,name=node,proto3" json:"node,omitempty"` Error *Error `protobuf:"bytes,25,opt,name=error,proto3" json:"error,omitempty"` PolicyName string `protobuf:"bytes,26,opt,name=policy_name,json=policyName,proto3" json:"policy_name,omitempty"` PolicyGroup string `protobuf:"bytes,27,opt,name=policy_group,json=policyGroup,proto3" json:"policy_group,omitempty"` Deprecations []*Deprecation `protobuf:"bytes,28,rep,name=deprecations,proto3" json:"deprecations,omitempty"` Tags []string `protobuf:"bytes,29,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*Run) Descriptor
deprecated
func (*Run) GetChefServerFqdn ¶
func (*Run) GetContent ¶
func (*Run) GetDeprecations ¶
func (x *Run) GetDeprecations() []*Deprecation
func (*Run) GetEndTime ¶
func (*Run) GetEntityUuid ¶
func (*Run) GetExpandedRunList ¶
func (x *Run) GetExpandedRunList() *ExpandedRunList
func (*Run) GetMessageType ¶
func (*Run) GetMessageVersion ¶
func (*Run) GetNodeName ¶
func (*Run) GetOrganizationName ¶
func (*Run) GetPolicyGroup ¶
func (*Run) GetPolicyName ¶
func (*Run) GetResources ¶
func (*Run) GetRunList ¶
func (*Run) GetStartTime ¶
func (*Run) GetTotalResourceCount ¶
func (*Run) GetUpdatedResourceCount ¶
func (*Run) ProtoMessage ¶
func (*Run) ProtoMessage()
func (*Run) ProtoReflect ¶
func (x *Run) ProtoReflect() protoreflect.Message
func (*Run) ToJSONBytes ¶
ToJSONBytes converts the Run message into a JSON Bytes
func (*Run) ToJSONString ¶
ToJSONString converts the Run message into a JSON String TODO @afiune Benchmark it!
type RunList ¶
type RunList struct { Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"` Skipped bool `protobuf:"varint,4,opt,name=skipped,proto3" json:"skipped,omitempty"` Children []*RunList `protobuf:"bytes,5,rep,name=children,proto3" json:"children,omitempty"` // contains filtered or unexported fields }
func (*RunList) Descriptor
deprecated
func (*RunList) GetChildren ¶
func (*RunList) GetSkipped ¶
func (*RunList) GetVersion ¶
func (*RunList) ProtoMessage ¶
func (*RunList) ProtoMessage()
func (*RunList) ProtoReflect ¶
func (x *RunList) ProtoReflect() protoreflect.Message
type SchedulerConfig ¶
type SchedulerConfig struct { Every string `protobuf:"bytes,1,opt,name=every,proto3" json:"every,omitempty"` Threshold string `protobuf:"bytes,2,opt,name=threshold,proto3" json:"threshold,omitempty"` Running bool `protobuf:"varint,3,opt,name=running,proto3" json:"running,omitempty"` // contains filtered or unexported fields }
SchedulerConfig The job message to configure the Delete Node Job every - It accepts '1h30m', '1m', '2h30m', ...
func (*SchedulerConfig) Descriptor
deprecated
func (*SchedulerConfig) Descriptor() ([]byte, []int)
Deprecated: Use SchedulerConfig.ProtoReflect.Descriptor instead.
func (*SchedulerConfig) GetEvery ¶
func (x *SchedulerConfig) GetEvery() string
func (*SchedulerConfig) GetRunning ¶
func (x *SchedulerConfig) GetRunning() bool
func (*SchedulerConfig) GetThreshold ¶
func (x *SchedulerConfig) GetThreshold() string
func (*SchedulerConfig) ProtoMessage ¶
func (*SchedulerConfig) ProtoMessage()
func (*SchedulerConfig) ProtoReflect ¶
func (x *SchedulerConfig) ProtoReflect() protoreflect.Message
func (*SchedulerConfig) Reset ¶
func (x *SchedulerConfig) Reset()
func (*SchedulerConfig) String ¶
func (x *SchedulerConfig) String() string
type StartDeleteNodesScheduler ¶
type StartDeleteNodesScheduler struct {
// contains filtered or unexported fields
}
func (*StartDeleteNodesScheduler) Descriptor
deprecated
func (*StartDeleteNodesScheduler) Descriptor() ([]byte, []int)
Deprecated: Use StartDeleteNodesScheduler.ProtoReflect.Descriptor instead.
func (*StartDeleteNodesScheduler) ProtoMessage ¶
func (*StartDeleteNodesScheduler) ProtoMessage()
func (*StartDeleteNodesScheduler) ProtoReflect ¶
func (x *StartDeleteNodesScheduler) ProtoReflect() protoreflect.Message
func (*StartDeleteNodesScheduler) Reset ¶
func (x *StartDeleteNodesScheduler) Reset()
func (*StartDeleteNodesScheduler) String ¶
func (x *StartDeleteNodesScheduler) String() string
type StartMissingNodesForDeletionScheduler ¶
type StartMissingNodesForDeletionScheduler struct {
// contains filtered or unexported fields
}
func (*StartMissingNodesForDeletionScheduler) Descriptor
deprecated
func (*StartMissingNodesForDeletionScheduler) Descriptor() ([]byte, []int)
Deprecated: Use StartMissingNodesForDeletionScheduler.ProtoReflect.Descriptor instead.
func (*StartMissingNodesForDeletionScheduler) ProtoMessage ¶
func (*StartMissingNodesForDeletionScheduler) ProtoMessage()
func (*StartMissingNodesForDeletionScheduler) ProtoReflect ¶
func (x *StartMissingNodesForDeletionScheduler) ProtoReflect() protoreflect.Message
func (*StartMissingNodesForDeletionScheduler) Reset ¶
func (x *StartMissingNodesForDeletionScheduler) Reset()
func (*StartMissingNodesForDeletionScheduler) String ¶
func (x *StartMissingNodesForDeletionScheduler) String() string
type StartNodesMissingScheduler ¶
type StartNodesMissingScheduler struct {
// contains filtered or unexported fields
}
func (*StartNodesMissingScheduler) Descriptor
deprecated
func (*StartNodesMissingScheduler) Descriptor() ([]byte, []int)
Deprecated: Use StartNodesMissingScheduler.ProtoReflect.Descriptor instead.
func (*StartNodesMissingScheduler) ProtoMessage ¶
func (*StartNodesMissingScheduler) ProtoMessage()
func (*StartNodesMissingScheduler) ProtoReflect ¶
func (x *StartNodesMissingScheduler) ProtoReflect() protoreflect.Message
func (*StartNodesMissingScheduler) Reset ¶
func (x *StartNodesMissingScheduler) Reset()
func (*StartNodesMissingScheduler) String ¶
func (x *StartNodesMissingScheduler) String() string
type StopDeleteNodesScheduler ¶
type StopDeleteNodesScheduler struct {
// contains filtered or unexported fields
}
func (*StopDeleteNodesScheduler) Descriptor
deprecated
func (*StopDeleteNodesScheduler) Descriptor() ([]byte, []int)
Deprecated: Use StopDeleteNodesScheduler.ProtoReflect.Descriptor instead.
func (*StopDeleteNodesScheduler) ProtoMessage ¶
func (*StopDeleteNodesScheduler) ProtoMessage()
func (*StopDeleteNodesScheduler) ProtoReflect ¶
func (x *StopDeleteNodesScheduler) ProtoReflect() protoreflect.Message
func (*StopDeleteNodesScheduler) Reset ¶
func (x *StopDeleteNodesScheduler) Reset()
func (*StopDeleteNodesScheduler) String ¶
func (x *StopDeleteNodesScheduler) String() string
type StopMissingNodesForDeletionScheduler ¶
type StopMissingNodesForDeletionScheduler struct {
// contains filtered or unexported fields
}
func (*StopMissingNodesForDeletionScheduler) Descriptor
deprecated
func (*StopMissingNodesForDeletionScheduler) Descriptor() ([]byte, []int)
Deprecated: Use StopMissingNodesForDeletionScheduler.ProtoReflect.Descriptor instead.
func (*StopMissingNodesForDeletionScheduler) ProtoMessage ¶
func (*StopMissingNodesForDeletionScheduler) ProtoMessage()
func (*StopMissingNodesForDeletionScheduler) ProtoReflect ¶
func (x *StopMissingNodesForDeletionScheduler) ProtoReflect() protoreflect.Message
func (*StopMissingNodesForDeletionScheduler) Reset ¶
func (x *StopMissingNodesForDeletionScheduler) Reset()
func (*StopMissingNodesForDeletionScheduler) String ¶
func (x *StopMissingNodesForDeletionScheduler) String() string
type StopNodesMissingScheduler ¶
type StopNodesMissingScheduler struct {
// contains filtered or unexported fields
}
func (*StopNodesMissingScheduler) Descriptor
deprecated
func (*StopNodesMissingScheduler) Descriptor() ([]byte, []int)
Deprecated: Use StopNodesMissingScheduler.ProtoReflect.Descriptor instead.
func (*StopNodesMissingScheduler) ProtoMessage ¶
func (*StopNodesMissingScheduler) ProtoMessage()
func (*StopNodesMissingScheduler) ProtoReflect ¶
func (x *StopNodesMissingScheduler) ProtoReflect() protoreflect.Message
func (*StopNodesMissingScheduler) Reset ¶
func (x *StopNodesMissingScheduler) Reset()
func (*StopNodesMissingScheduler) String ¶
func (x *StopNodesMissingScheduler) String() string