Documentation
¶
Overview ¶
Package sessionv2 defines the single-connection GPUd session protocol.
Index ¶
- Constants
- Variables
- func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)
- type ActivateKAPMTLSRequest
- type AgentPacket
- func (*AgentPacket) Descriptor() ([]byte, []int)deprecated
- func (x *AgentPacket) GetHello() *Hello
- func (x *AgentPacket) GetPayload() isAgentPacket_Payload
- func (x *AgentPacket) GetResult() *Result
- func (*AgentPacket) ProtoMessage()
- func (x *AgentPacket) ProtoReflect() protoreflect.Message
- func (x *AgentPacket) Reset()
- func (x *AgentPacket) String() string
- type AgentPacket_Hello
- type AgentPacket_Result
- type BashScript
- type BootstrapRequest
- func (*BootstrapRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BootstrapRequest) GetRequestPresent() bool
- func (x *BootstrapRequest) GetScriptBase64() string
- func (x *BootstrapRequest) GetTimeoutSeconds() int64
- func (*BootstrapRequest) ProtoMessage()
- func (x *BootstrapRequest) ProtoReflect() protoreflect.Message
- func (x *BootstrapRequest) Reset()
- func (x *BootstrapRequest) String() string
- type DiagnosticRequest
- func (*DiagnosticRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DiagnosticRequest) GetReportId() string
- func (x *DiagnosticRequest) GetRequestPresent() bool
- func (x *DiagnosticRequest) GetTimeoutSeconds() int64
- func (x *DiagnosticRequest) GetType() string
- func (*DiagnosticRequest) ProtoMessage()
- func (x *DiagnosticRequest) ProtoReflect() protoreflect.Message
- func (x *DiagnosticRequest) Reset()
- func (x *DiagnosticRequest) String() string
- type DrainNotice
- type GetEventsRequest
- func (*GetEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventsRequest) GetEndTime() *timestamppb.Timestamp
- func (x *GetEventsRequest) GetStartTime() *timestamppb.Timestamp
- func (*GetEventsRequest) ProtoMessage()
- func (x *GetEventsRequest) ProtoReflect() protoreflect.Message
- func (x *GetEventsRequest) Reset()
- func (x *GetEventsRequest) String() string
- type GetHealthStatesRequest
- type GetKAPMTLSStatusRequest
- type GetMetricsRequest
- type GetPackageStatusRequest
- type GossipRequest
- type Hello
- func (*Hello) Descriptor() ([]byte, []int)deprecated
- func (x *Hello) GetAgentVersion() string
- func (x *Hello) GetCapabilities() []string
- func (x *Hello) GetMaxProtocolRevision() uint32
- func (x *Hello) GetMaxReceiveMessageBytes() uint32
- func (x *Hello) GetMinProtocolRevision() uint32
- func (*Hello) ProtoMessage()
- func (x *Hello) ProtoReflect() protoreflect.Message
- func (x *Hello) Reset()
- func (x *Hello) String() string
- type HelloAck
- func (*HelloAck) Descriptor() ([]byte, []int)deprecated
- func (x *HelloAck) GetManagerInstanceId() string
- func (x *HelloAck) GetMaxReceiveMessageBytes() uint32
- func (x *HelloAck) GetProtocolRevision() uint32
- func (*HelloAck) ProtoMessage()
- func (x *HelloAck) ProtoReflect() protoreflect.Message
- func (x *HelloAck) Reset()
- func (x *HelloAck) String() string
- type InjectFaultRequest
- func (*InjectFaultRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InjectFaultRequest) GetFault() isInjectFaultRequest_Fault
- func (x *InjectFaultRequest) GetKernelMessage() *KernelMessage
- func (x *InjectFaultRequest) GetRequestPresent() bool
- func (x *InjectFaultRequest) GetXid() int64
- func (*InjectFaultRequest) ProtoMessage()
- func (x *InjectFaultRequest) ProtoReflect() protoreflect.Message
- func (x *InjectFaultRequest) Reset()
- func (x *InjectFaultRequest) String() string
- type InjectFaultRequest_KernelMessage
- type InjectFaultRequest_Xid
- type KernelMessage
- func (*KernelMessage) Descriptor() ([]byte, []int)deprecated
- func (x *KernelMessage) GetMessage() string
- func (x *KernelMessage) GetPriority() string
- func (*KernelMessage) ProtoMessage()
- func (x *KernelMessage) ProtoReflect() protoreflect.Message
- func (x *KernelMessage) Reset()
- func (x *KernelMessage) String() string
- type LogoutRequest
- type ManagerPacket
- func (*ManagerPacket) Descriptor() ([]byte, []int)deprecated
- func (x *ManagerPacket) GetActivateKapMtls() *ActivateKAPMTLSRequest
- func (x *ManagerPacket) GetBootstrap() *BootstrapRequest
- func (x *ManagerPacket) GetDiagnostic() *DiagnosticRequest
- func (x *ManagerPacket) GetDrainNotice() *DrainNotice
- func (x *ManagerPacket) GetGetEvents() *GetEventsRequest
- func (x *ManagerPacket) GetGetHealthStates() *GetHealthStatesRequest
- func (x *ManagerPacket) GetGetKapMtlsStatus() *GetKAPMTLSStatusRequest
- func (x *ManagerPacket) GetGetMetrics() *GetMetricsRequest
- func (x *ManagerPacket) GetGetPackageStatus() *GetPackageStatusRequest
- func (x *ManagerPacket) GetGossip() *GossipRequest
- func (x *ManagerPacket) GetHelloAck() *HelloAck
- func (x *ManagerPacket) GetInjectFault() *InjectFaultRequest
- func (x *ManagerPacket) GetLogout() *LogoutRequest
- func (x *ManagerPacket) GetPayload() isManagerPacket_Payload
- func (x *ManagerPacket) GetReboot() *RebootRequest
- func (x *ManagerPacket) GetRequestId() string
- func (x *ManagerPacket) GetSetHealthy() *SetHealthyRequest
- func (x *ManagerPacket) GetSetPluginSpecs() *SetPluginSpecsRequest
- func (x *ManagerPacket) GetTriggerComponent() *TriggerComponentRequest
- func (x *ManagerPacket) GetUpdate() *UpdateRequest
- func (x *ManagerPacket) GetUpdateConfig() *UpdateConfigRequest
- func (x *ManagerPacket) GetUpdateKapMtlsCredentials() *UpdateKAPMTLSCredentialsRequest
- func (x *ManagerPacket) GetUpdateToken() *UpdateTokenRequest
- func (*ManagerPacket) ProtoMessage()
- func (x *ManagerPacket) ProtoReflect() protoreflect.Message
- func (x *ManagerPacket) Reset()
- func (x *ManagerPacket) String() string
- type ManagerPacket_ActivateKapMtls
- type ManagerPacket_Bootstrap
- type ManagerPacket_Diagnostic
- type ManagerPacket_DrainNotice
- type ManagerPacket_GetEvents
- type ManagerPacket_GetHealthStates
- type ManagerPacket_GetKapMtlsStatus
- type ManagerPacket_GetMetrics
- type ManagerPacket_GetPackageStatus
- type ManagerPacket_Gossip
- type ManagerPacket_HelloAck
- type ManagerPacket_InjectFault
- type ManagerPacket_Logout
- type ManagerPacket_Reboot
- type ManagerPacket_SetHealthy
- type ManagerPacket_SetPluginSpecs
- type ManagerPacket_TriggerComponent
- type ManagerPacket_Update
- type ManagerPacket_UpdateConfig
- type ManagerPacket_UpdateKapMtlsCredentials
- type ManagerPacket_UpdateToken
- type Plugin
- type PluginJSONPath
- func (*PluginJSONPath) Descriptor() ([]byte, []int)deprecated
- func (x *PluginJSONPath) GetExpect() *PluginMatchRule
- func (x *PluginJSONPath) GetField() string
- func (x *PluginJSONPath) GetQuery() string
- func (x *PluginJSONPath) GetSuggestedActions() map[string]*PluginMatchRule
- func (*PluginJSONPath) ProtoMessage()
- func (x *PluginJSONPath) ProtoReflect() protoreflect.Message
- func (x *PluginJSONPath) Reset()
- func (x *PluginJSONPath) String() string
- type PluginMatchRule
- type PluginOutputParser
- func (*PluginOutputParser) Descriptor() ([]byte, []int)deprecated
- func (x *PluginOutputParser) GetJsonPaths() []*PluginJSONPath
- func (x *PluginOutputParser) GetLogPath() string
- func (*PluginOutputParser) ProtoMessage()
- func (x *PluginOutputParser) ProtoReflect() protoreflect.Message
- func (x *PluginOutputParser) Reset()
- func (x *PluginOutputParser) String() string
- type PluginSpec
- func (*PluginSpec) Descriptor() ([]byte, []int)deprecated
- func (x *PluginSpec) GetComponentList() []string
- func (x *PluginSpec) GetComponentListFile() string
- func (x *PluginSpec) GetHealthStatePlugin() *Plugin
- func (x *PluginSpec) GetIntervalNanos() int64
- func (x *PluginSpec) GetPluginName() string
- func (x *PluginSpec) GetPluginType() string
- func (x *PluginSpec) GetRunMode() string
- func (x *PluginSpec) GetTags() []string
- func (x *PluginSpec) GetTimeoutNanos() int64
- func (*PluginSpec) ProtoMessage()
- func (x *PluginSpec) ProtoReflect() protoreflect.Message
- func (x *PluginSpec) Reset()
- func (x *PluginSpec) String() string
- type PluginStep
- func (*PluginStep) Descriptor() ([]byte, []int)deprecated
- func (x *PluginStep) GetName() string
- func (x *PluginStep) GetRunBashScript() *BashScript
- func (*PluginStep) ProtoMessage()
- func (x *PluginStep) ProtoReflect() protoreflect.Message
- func (x *PluginStep) Reset()
- func (x *PluginStep) String() string
- type RebootRequest
- type Result
- type SessionServiceClient
- type SessionServiceServer
- type SessionService_ConnectClient
- type SessionService_ConnectServer
- type SetHealthyRequest
- func (*SetHealthyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetHealthyRequest) GetComponents() []string
- func (x *SetHealthyRequest) GetSinceNanos() int64
- func (*SetHealthyRequest) ProtoMessage()
- func (x *SetHealthyRequest) ProtoReflect() protoreflect.Message
- func (x *SetHealthyRequest) Reset()
- func (x *SetHealthyRequest) String() string
- type SetPluginSpecsRequest
- func (*SetPluginSpecsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetPluginSpecsRequest) GetSpecs() []*PluginSpec
- func (x *SetPluginSpecsRequest) GetSpecsPresent() bool
- func (*SetPluginSpecsRequest) ProtoMessage()
- func (x *SetPluginSpecsRequest) ProtoReflect() protoreflect.Message
- func (x *SetPluginSpecsRequest) Reset()
- func (x *SetPluginSpecsRequest) String() string
- type TriggerComponentRequest
- func (*TriggerComponentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TriggerComponentRequest) GetComponentName() string
- func (x *TriggerComponentRequest) GetTagName() string
- func (*TriggerComponentRequest) ProtoMessage()
- func (x *TriggerComponentRequest) ProtoReflect() protoreflect.Message
- func (x *TriggerComponentRequest) Reset()
- func (x *TriggerComponentRequest) String() string
- type UnimplementedSessionServiceServer
- type UnsafeSessionServiceServer
- type UpdateConfigRequest
- func (*UpdateConfigRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateConfigRequest) GetValues() map[string]string
- func (*UpdateConfigRequest) ProtoMessage()
- func (x *UpdateConfigRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateConfigRequest) Reset()
- func (x *UpdateConfigRequest) String() string
- type UpdateKAPMTLSCredentialsRequest
- func (*UpdateKAPMTLSCredentialsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateKAPMTLSCredentialsRequest) GetCertificatePem() []byte
- func (x *UpdateKAPMTLSCredentialsRequest) GetClientCaFingerprint() string
- func (x *UpdateKAPMTLSCredentialsRequest) GetGatewayCaFingerprint() string
- func (x *UpdateKAPMTLSCredentialsRequest) GetGatewayCaPem() []byte
- func (x *UpdateKAPMTLSCredentialsRequest) GetGatewayEndpoint() string
- func (x *UpdateKAPMTLSCredentialsRequest) GetPrivateKeyPem() []byte
- func (x *UpdateKAPMTLSCredentialsRequest) GetServerName() string
- func (*UpdateKAPMTLSCredentialsRequest) ProtoMessage()
- func (x *UpdateKAPMTLSCredentialsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateKAPMTLSCredentialsRequest) Reset()
- func (x *UpdateKAPMTLSCredentialsRequest) String() string
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetSinceNanos() int64
- func (x *UpdateRequest) GetVersion() string
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
- type UpdateTokenRequest
- func (*UpdateTokenRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateTokenRequest) GetToken() string
- func (*UpdateTokenRequest) ProtoMessage()
- func (x *UpdateTokenRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateTokenRequest) Reset()
- func (x *UpdateTokenRequest) String() string
Constants ¶
const ( ProtocolRevision = 1 MetadataAuthorization = "authorization" MetadataMachineID = "x-gpud-machine-id" MetadataMachineProof = "x-gpud-machine-proof" )
const DefaultMaxMessageBytes = 8 * 1024 * 1024
const (
SessionService_Connect_FullMethodName = "/gpud.session.v2.SessionService/Connect"
)
Variables ¶
var File_session_proto protoreflect.FileDescriptor
var SessionService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "gpud.session.v2.SessionService", HandlerType: (*SessionServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Connect", Handler: _SessionService_Connect_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "session.proto", }
SessionService_ServiceDesc is the grpc.ServiceDesc for SessionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSessionServiceServer ¶
func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)
Types ¶
type ActivateKAPMTLSRequest ¶
type ActivateKAPMTLSRequest struct {
// contains filtered or unexported fields
}
func (*ActivateKAPMTLSRequest) Descriptor
deprecated
func (*ActivateKAPMTLSRequest) Descriptor() ([]byte, []int)
Deprecated: Use ActivateKAPMTLSRequest.ProtoReflect.Descriptor instead.
func (*ActivateKAPMTLSRequest) ProtoMessage ¶
func (*ActivateKAPMTLSRequest) ProtoMessage()
func (*ActivateKAPMTLSRequest) ProtoReflect ¶
func (x *ActivateKAPMTLSRequest) ProtoReflect() protoreflect.Message
func (*ActivateKAPMTLSRequest) Reset ¶
func (x *ActivateKAPMTLSRequest) Reset()
func (*ActivateKAPMTLSRequest) String ¶
func (x *ActivateKAPMTLSRequest) String() string
type AgentPacket ¶
type AgentPacket struct {
// Types that are valid to be assigned to Payload:
//
// *AgentPacket_Hello
// *AgentPacket_Result
Payload isAgentPacket_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*AgentPacket) Descriptor
deprecated
func (*AgentPacket) Descriptor() ([]byte, []int)
Deprecated: Use AgentPacket.ProtoReflect.Descriptor instead.
func (*AgentPacket) GetHello ¶
func (x *AgentPacket) GetHello() *Hello
func (*AgentPacket) GetPayload ¶
func (x *AgentPacket) GetPayload() isAgentPacket_Payload
func (*AgentPacket) GetResult ¶
func (x *AgentPacket) GetResult() *Result
func (*AgentPacket) ProtoMessage ¶
func (*AgentPacket) ProtoMessage()
func (*AgentPacket) ProtoReflect ¶
func (x *AgentPacket) ProtoReflect() protoreflect.Message
func (*AgentPacket) Reset ¶
func (x *AgentPacket) Reset()
func (*AgentPacket) String ¶
func (x *AgentPacket) String() string
type AgentPacket_Hello ¶
type AgentPacket_Hello struct {
Hello *Hello `protobuf:"bytes,1,opt,name=hello,proto3,oneof"`
}
type AgentPacket_Result ¶
type AgentPacket_Result struct {
Result *Result `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}
type BashScript ¶
type BashScript struct {
ContentType string `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
Script string `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
// contains filtered or unexported fields
}
func (*BashScript) Descriptor
deprecated
func (*BashScript) Descriptor() ([]byte, []int)
Deprecated: Use BashScript.ProtoReflect.Descriptor instead.
func (*BashScript) GetContentType ¶
func (x *BashScript) GetContentType() string
func (*BashScript) GetScript ¶
func (x *BashScript) GetScript() string
func (*BashScript) ProtoMessage ¶
func (*BashScript) ProtoMessage()
func (*BashScript) ProtoReflect ¶
func (x *BashScript) ProtoReflect() protoreflect.Message
func (*BashScript) Reset ¶
func (x *BashScript) Reset()
func (*BashScript) String ¶
func (x *BashScript) String() string
type BootstrapRequest ¶
type BootstrapRequest struct {
TimeoutSeconds int64 `protobuf:"varint,1,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
ScriptBase64 string `protobuf:"bytes,2,opt,name=script_base64,json=scriptBase64,proto3" json:"script_base64,omitempty"`
RequestPresent bool `protobuf:"varint,3,opt,name=request_present,json=requestPresent,proto3" json:"request_present,omitempty"`
// contains filtered or unexported fields
}
func (*BootstrapRequest) Descriptor
deprecated
func (*BootstrapRequest) Descriptor() ([]byte, []int)
Deprecated: Use BootstrapRequest.ProtoReflect.Descriptor instead.
func (*BootstrapRequest) GetRequestPresent ¶
func (x *BootstrapRequest) GetRequestPresent() bool
func (*BootstrapRequest) GetScriptBase64 ¶
func (x *BootstrapRequest) GetScriptBase64() string
func (*BootstrapRequest) GetTimeoutSeconds ¶
func (x *BootstrapRequest) GetTimeoutSeconds() int64
func (*BootstrapRequest) ProtoMessage ¶
func (*BootstrapRequest) ProtoMessage()
func (*BootstrapRequest) ProtoReflect ¶
func (x *BootstrapRequest) ProtoReflect() protoreflect.Message
func (*BootstrapRequest) Reset ¶
func (x *BootstrapRequest) Reset()
func (*BootstrapRequest) String ¶
func (x *BootstrapRequest) String() string
type DiagnosticRequest ¶
type DiagnosticRequest struct {
ReportId string `protobuf:"bytes,1,opt,name=report_id,json=reportId,proto3" json:"report_id,omitempty"`
Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
TimeoutSeconds int64 `protobuf:"varint,3,opt,name=timeout_seconds,json=timeoutSeconds,proto3" json:"timeout_seconds,omitempty"`
RequestPresent bool `protobuf:"varint,4,opt,name=request_present,json=requestPresent,proto3" json:"request_present,omitempty"`
// contains filtered or unexported fields
}
func (*DiagnosticRequest) Descriptor
deprecated
func (*DiagnosticRequest) Descriptor() ([]byte, []int)
Deprecated: Use DiagnosticRequest.ProtoReflect.Descriptor instead.
func (*DiagnosticRequest) GetReportId ¶
func (x *DiagnosticRequest) GetReportId() string
func (*DiagnosticRequest) GetRequestPresent ¶
func (x *DiagnosticRequest) GetRequestPresent() bool
func (*DiagnosticRequest) GetTimeoutSeconds ¶
func (x *DiagnosticRequest) GetTimeoutSeconds() int64
func (*DiagnosticRequest) GetType ¶
func (x *DiagnosticRequest) GetType() string
func (*DiagnosticRequest) ProtoMessage ¶
func (*DiagnosticRequest) ProtoMessage()
func (*DiagnosticRequest) ProtoReflect ¶
func (x *DiagnosticRequest) ProtoReflect() protoreflect.Message
func (*DiagnosticRequest) Reset ¶
func (x *DiagnosticRequest) Reset()
func (*DiagnosticRequest) String ¶
func (x *DiagnosticRequest) String() string
type DrainNotice ¶
type DrainNotice struct {
ReconnectAfterMillis int64 `protobuf:"varint,1,opt,name=reconnect_after_millis,json=reconnectAfterMillis,proto3" json:"reconnect_after_millis,omitempty"`
// contains filtered or unexported fields
}
func (*DrainNotice) Descriptor
deprecated
func (*DrainNotice) Descriptor() ([]byte, []int)
Deprecated: Use DrainNotice.ProtoReflect.Descriptor instead.
func (*DrainNotice) GetReconnectAfterMillis ¶
func (x *DrainNotice) GetReconnectAfterMillis() int64
func (*DrainNotice) ProtoMessage ¶
func (*DrainNotice) ProtoMessage()
func (*DrainNotice) ProtoReflect ¶
func (x *DrainNotice) ProtoReflect() protoreflect.Message
func (*DrainNotice) Reset ¶
func (x *DrainNotice) Reset()
func (*DrainNotice) String ¶
func (x *DrainNotice) String() string
type GetEventsRequest ¶
type GetEventsRequest struct {
StartTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
// contains filtered or unexported fields
}
func (*GetEventsRequest) Descriptor
deprecated
func (*GetEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEventsRequest.ProtoReflect.Descriptor instead.
func (*GetEventsRequest) GetEndTime ¶
func (x *GetEventsRequest) GetEndTime() *timestamppb.Timestamp
func (*GetEventsRequest) GetStartTime ¶
func (x *GetEventsRequest) GetStartTime() *timestamppb.Timestamp
func (*GetEventsRequest) ProtoMessage ¶
func (*GetEventsRequest) ProtoMessage()
func (*GetEventsRequest) ProtoReflect ¶
func (x *GetEventsRequest) ProtoReflect() protoreflect.Message
func (*GetEventsRequest) Reset ¶
func (x *GetEventsRequest) Reset()
func (*GetEventsRequest) String ¶
func (x *GetEventsRequest) String() string
type GetHealthStatesRequest ¶
type GetHealthStatesRequest struct {
// contains filtered or unexported fields
}
func (*GetHealthStatesRequest) Descriptor
deprecated
func (*GetHealthStatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHealthStatesRequest.ProtoReflect.Descriptor instead.
func (*GetHealthStatesRequest) ProtoMessage ¶
func (*GetHealthStatesRequest) ProtoMessage()
func (*GetHealthStatesRequest) ProtoReflect ¶
func (x *GetHealthStatesRequest) ProtoReflect() protoreflect.Message
func (*GetHealthStatesRequest) Reset ¶
func (x *GetHealthStatesRequest) Reset()
func (*GetHealthStatesRequest) String ¶
func (x *GetHealthStatesRequest) String() string
type GetKAPMTLSStatusRequest ¶
type GetKAPMTLSStatusRequest struct {
// contains filtered or unexported fields
}
func (*GetKAPMTLSStatusRequest) Descriptor
deprecated
func (*GetKAPMTLSStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetKAPMTLSStatusRequest.ProtoReflect.Descriptor instead.
func (*GetKAPMTLSStatusRequest) ProtoMessage ¶
func (*GetKAPMTLSStatusRequest) ProtoMessage()
func (*GetKAPMTLSStatusRequest) ProtoReflect ¶
func (x *GetKAPMTLSStatusRequest) ProtoReflect() protoreflect.Message
func (*GetKAPMTLSStatusRequest) Reset ¶
func (x *GetKAPMTLSStatusRequest) Reset()
func (*GetKAPMTLSStatusRequest) String ¶
func (x *GetKAPMTLSStatusRequest) String() string
type GetMetricsRequest ¶
type GetMetricsRequest struct {
SinceNanos int64 `protobuf:"varint,1,opt,name=since_nanos,json=sinceNanos,proto3" json:"since_nanos,omitempty"`
// contains filtered or unexported fields
}
func (*GetMetricsRequest) Descriptor
deprecated
func (*GetMetricsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricsRequest.ProtoReflect.Descriptor instead.
func (*GetMetricsRequest) GetSinceNanos ¶
func (x *GetMetricsRequest) GetSinceNanos() int64
func (*GetMetricsRequest) ProtoMessage ¶
func (*GetMetricsRequest) ProtoMessage()
func (*GetMetricsRequest) ProtoReflect ¶
func (x *GetMetricsRequest) ProtoReflect() protoreflect.Message
func (*GetMetricsRequest) Reset ¶
func (x *GetMetricsRequest) Reset()
func (*GetMetricsRequest) String ¶
func (x *GetMetricsRequest) String() string
type GetPackageStatusRequest ¶
type GetPackageStatusRequest struct {
// contains filtered or unexported fields
}
func (*GetPackageStatusRequest) Descriptor
deprecated
func (*GetPackageStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPackageStatusRequest.ProtoReflect.Descriptor instead.
func (*GetPackageStatusRequest) ProtoMessage ¶
func (*GetPackageStatusRequest) ProtoMessage()
func (*GetPackageStatusRequest) ProtoReflect ¶
func (x *GetPackageStatusRequest) ProtoReflect() protoreflect.Message
func (*GetPackageStatusRequest) Reset ¶
func (x *GetPackageStatusRequest) Reset()
func (*GetPackageStatusRequest) String ¶
func (x *GetPackageStatusRequest) String() string
type GossipRequest ¶
type GossipRequest struct {
// contains filtered or unexported fields
}
func (*GossipRequest) Descriptor
deprecated
func (*GossipRequest) Descriptor() ([]byte, []int)
Deprecated: Use GossipRequest.ProtoReflect.Descriptor instead.
func (*GossipRequest) ProtoMessage ¶
func (*GossipRequest) ProtoMessage()
func (*GossipRequest) ProtoReflect ¶
func (x *GossipRequest) ProtoReflect() protoreflect.Message
func (*GossipRequest) Reset ¶
func (x *GossipRequest) Reset()
func (*GossipRequest) String ¶
func (x *GossipRequest) String() string
type Hello ¶
type Hello struct {
MinProtocolRevision uint32 `protobuf:"varint,1,opt,name=min_protocol_revision,json=minProtocolRevision,proto3" json:"min_protocol_revision,omitempty"`
MaxProtocolRevision uint32 `protobuf:"varint,2,opt,name=max_protocol_revision,json=maxProtocolRevision,proto3" json:"max_protocol_revision,omitempty"`
AgentVersion string `protobuf:"bytes,3,opt,name=agent_version,json=agentVersion,proto3" json:"agent_version,omitempty"`
MaxReceiveMessageBytes uint32 `` /* 132-byte string literal not displayed */
Capabilities []string `protobuf:"bytes,5,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
// contains filtered or unexported fields
}
func (*Hello) Descriptor
deprecated
func (*Hello) GetAgentVersion ¶
func (*Hello) GetCapabilities ¶
func (*Hello) GetMaxProtocolRevision ¶
func (*Hello) GetMaxReceiveMessageBytes ¶
func (*Hello) GetMinProtocolRevision ¶
func (*Hello) ProtoMessage ¶
func (*Hello) ProtoMessage()
func (*Hello) ProtoReflect ¶
func (x *Hello) ProtoReflect() protoreflect.Message
type HelloAck ¶
type HelloAck struct {
ProtocolRevision uint32 `protobuf:"varint,1,opt,name=protocol_revision,json=protocolRevision,proto3" json:"protocol_revision,omitempty"`
ManagerInstanceId string `protobuf:"bytes,2,opt,name=manager_instance_id,json=managerInstanceId,proto3" json:"manager_instance_id,omitempty"`
MaxReceiveMessageBytes uint32 `` /* 132-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*HelloAck) Descriptor
deprecated
func (*HelloAck) GetManagerInstanceId ¶
func (*HelloAck) GetMaxReceiveMessageBytes ¶
func (*HelloAck) GetProtocolRevision ¶
func (*HelloAck) ProtoMessage ¶
func (*HelloAck) ProtoMessage()
func (*HelloAck) ProtoReflect ¶
func (x *HelloAck) ProtoReflect() protoreflect.Message
type InjectFaultRequest ¶
type InjectFaultRequest struct {
RequestPresent bool `protobuf:"varint,1,opt,name=request_present,json=requestPresent,proto3" json:"request_present,omitempty"`
// Types that are valid to be assigned to Fault:
//
// *InjectFaultRequest_Xid
// *InjectFaultRequest_KernelMessage
Fault isInjectFaultRequest_Fault `protobuf_oneof:"fault"`
// contains filtered or unexported fields
}
func (*InjectFaultRequest) Descriptor
deprecated
func (*InjectFaultRequest) Descriptor() ([]byte, []int)
Deprecated: Use InjectFaultRequest.ProtoReflect.Descriptor instead.
func (*InjectFaultRequest) GetFault ¶
func (x *InjectFaultRequest) GetFault() isInjectFaultRequest_Fault
func (*InjectFaultRequest) GetKernelMessage ¶
func (x *InjectFaultRequest) GetKernelMessage() *KernelMessage
func (*InjectFaultRequest) GetRequestPresent ¶
func (x *InjectFaultRequest) GetRequestPresent() bool
func (*InjectFaultRequest) GetXid ¶
func (x *InjectFaultRequest) GetXid() int64
func (*InjectFaultRequest) ProtoMessage ¶
func (*InjectFaultRequest) ProtoMessage()
func (*InjectFaultRequest) ProtoReflect ¶
func (x *InjectFaultRequest) ProtoReflect() protoreflect.Message
func (*InjectFaultRequest) Reset ¶
func (x *InjectFaultRequest) Reset()
func (*InjectFaultRequest) String ¶
func (x *InjectFaultRequest) String() string
type InjectFaultRequest_KernelMessage ¶
type InjectFaultRequest_KernelMessage struct {
KernelMessage *KernelMessage `protobuf:"bytes,3,opt,name=kernel_message,json=kernelMessage,proto3,oneof"`
}
type InjectFaultRequest_Xid ¶
type InjectFaultRequest_Xid struct {
Xid int64 `protobuf:"varint,2,opt,name=xid,proto3,oneof"`
}
type KernelMessage ¶
type KernelMessage struct {
Priority string `protobuf:"bytes,1,opt,name=priority,proto3" json:"priority,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*KernelMessage) Descriptor
deprecated
func (*KernelMessage) Descriptor() ([]byte, []int)
Deprecated: Use KernelMessage.ProtoReflect.Descriptor instead.
func (*KernelMessage) GetMessage ¶
func (x *KernelMessage) GetMessage() string
func (*KernelMessage) GetPriority ¶
func (x *KernelMessage) GetPriority() string
func (*KernelMessage) ProtoMessage ¶
func (*KernelMessage) ProtoMessage()
func (*KernelMessage) ProtoReflect ¶
func (x *KernelMessage) ProtoReflect() protoreflect.Message
func (*KernelMessage) Reset ¶
func (x *KernelMessage) Reset()
func (*KernelMessage) String ¶
func (x *KernelMessage) String() string
type LogoutRequest ¶
type LogoutRequest struct {
// contains filtered or unexported fields
}
func (*LogoutRequest) Descriptor
deprecated
func (*LogoutRequest) Descriptor() ([]byte, []int)
Deprecated: Use LogoutRequest.ProtoReflect.Descriptor instead.
func (*LogoutRequest) ProtoMessage ¶
func (*LogoutRequest) ProtoMessage()
func (*LogoutRequest) ProtoReflect ¶
func (x *LogoutRequest) ProtoReflect() protoreflect.Message
func (*LogoutRequest) Reset ¶
func (x *LogoutRequest) Reset()
func (*LogoutRequest) String ¶
func (x *LogoutRequest) String() string
type ManagerPacket ¶
type ManagerPacket struct {
RequestId string `protobuf:"bytes,4,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// Types that are valid to be assigned to Payload:
//
// *ManagerPacket_HelloAck
// *ManagerPacket_DrainNotice
// *ManagerPacket_GetHealthStates
// *ManagerPacket_GetEvents
// *ManagerPacket_GetMetrics
// *ManagerPacket_Update
// *ManagerPacket_SetHealthy
// *ManagerPacket_Reboot
// *ManagerPacket_UpdateConfig
// *ManagerPacket_Bootstrap
// *ManagerPacket_InjectFault
// *ManagerPacket_Diagnostic
// *ManagerPacket_GetPackageStatus
// *ManagerPacket_Logout
// *ManagerPacket_Gossip
// *ManagerPacket_TriggerComponent
// *ManagerPacket_SetPluginSpecs
// *ManagerPacket_UpdateToken
// *ManagerPacket_GetKapMtlsStatus
// *ManagerPacket_UpdateKapMtlsCredentials
// *ManagerPacket_ActivateKapMtls
Payload isManagerPacket_Payload `protobuf_oneof:"payload"`
// contains filtered or unexported fields
}
func (*ManagerPacket) Descriptor
deprecated
func (*ManagerPacket) Descriptor() ([]byte, []int)
Deprecated: Use ManagerPacket.ProtoReflect.Descriptor instead.
func (*ManagerPacket) GetActivateKapMtls ¶
func (x *ManagerPacket) GetActivateKapMtls() *ActivateKAPMTLSRequest
func (*ManagerPacket) GetBootstrap ¶
func (x *ManagerPacket) GetBootstrap() *BootstrapRequest
func (*ManagerPacket) GetDiagnostic ¶
func (x *ManagerPacket) GetDiagnostic() *DiagnosticRequest
func (*ManagerPacket) GetDrainNotice ¶
func (x *ManagerPacket) GetDrainNotice() *DrainNotice
func (*ManagerPacket) GetGetEvents ¶
func (x *ManagerPacket) GetGetEvents() *GetEventsRequest
func (*ManagerPacket) GetGetHealthStates ¶
func (x *ManagerPacket) GetGetHealthStates() *GetHealthStatesRequest
func (*ManagerPacket) GetGetKapMtlsStatus ¶
func (x *ManagerPacket) GetGetKapMtlsStatus() *GetKAPMTLSStatusRequest
func (*ManagerPacket) GetGetMetrics ¶
func (x *ManagerPacket) GetGetMetrics() *GetMetricsRequest
func (*ManagerPacket) GetGetPackageStatus ¶
func (x *ManagerPacket) GetGetPackageStatus() *GetPackageStatusRequest
func (*ManagerPacket) GetGossip ¶
func (x *ManagerPacket) GetGossip() *GossipRequest
func (*ManagerPacket) GetHelloAck ¶
func (x *ManagerPacket) GetHelloAck() *HelloAck
func (*ManagerPacket) GetInjectFault ¶
func (x *ManagerPacket) GetInjectFault() *InjectFaultRequest
func (*ManagerPacket) GetLogout ¶
func (x *ManagerPacket) GetLogout() *LogoutRequest
func (*ManagerPacket) GetPayload ¶
func (x *ManagerPacket) GetPayload() isManagerPacket_Payload
func (*ManagerPacket) GetReboot ¶
func (x *ManagerPacket) GetReboot() *RebootRequest
func (*ManagerPacket) GetRequestId ¶
func (x *ManagerPacket) GetRequestId() string
func (*ManagerPacket) GetSetHealthy ¶
func (x *ManagerPacket) GetSetHealthy() *SetHealthyRequest
func (*ManagerPacket) GetSetPluginSpecs ¶
func (x *ManagerPacket) GetSetPluginSpecs() *SetPluginSpecsRequest
func (*ManagerPacket) GetTriggerComponent ¶
func (x *ManagerPacket) GetTriggerComponent() *TriggerComponentRequest
func (*ManagerPacket) GetUpdate ¶
func (x *ManagerPacket) GetUpdate() *UpdateRequest
func (*ManagerPacket) GetUpdateConfig ¶
func (x *ManagerPacket) GetUpdateConfig() *UpdateConfigRequest
func (*ManagerPacket) GetUpdateKapMtlsCredentials ¶
func (x *ManagerPacket) GetUpdateKapMtlsCredentials() *UpdateKAPMTLSCredentialsRequest
func (*ManagerPacket) GetUpdateToken ¶
func (x *ManagerPacket) GetUpdateToken() *UpdateTokenRequest
func (*ManagerPacket) ProtoMessage ¶
func (*ManagerPacket) ProtoMessage()
func (*ManagerPacket) ProtoReflect ¶
func (x *ManagerPacket) ProtoReflect() protoreflect.Message
func (*ManagerPacket) Reset ¶
func (x *ManagerPacket) Reset()
func (*ManagerPacket) String ¶
func (x *ManagerPacket) String() string
type ManagerPacket_ActivateKapMtls ¶
type ManagerPacket_ActivateKapMtls struct {
ActivateKapMtls *ActivateKAPMTLSRequest `protobuf:"bytes,28,opt,name=activate_kap_mtls,json=activateKapMtls,proto3,oneof"`
}
type ManagerPacket_Bootstrap ¶
type ManagerPacket_Bootstrap struct {
Bootstrap *BootstrapRequest `protobuf:"bytes,17,opt,name=bootstrap,proto3,oneof"`
}
type ManagerPacket_Diagnostic ¶
type ManagerPacket_Diagnostic struct {
Diagnostic *DiagnosticRequest `protobuf:"bytes,19,opt,name=diagnostic,proto3,oneof"`
}
type ManagerPacket_DrainNotice ¶
type ManagerPacket_DrainNotice struct {
DrainNotice *DrainNotice `protobuf:"bytes,3,opt,name=drain_notice,json=drainNotice,proto3,oneof"`
}
type ManagerPacket_GetEvents ¶
type ManagerPacket_GetEvents struct {
GetEvents *GetEventsRequest `protobuf:"bytes,11,opt,name=get_events,json=getEvents,proto3,oneof"`
}
type ManagerPacket_GetHealthStates ¶
type ManagerPacket_GetHealthStates struct {
GetHealthStates *GetHealthStatesRequest `protobuf:"bytes,10,opt,name=get_health_states,json=getHealthStates,proto3,oneof"`
}
type ManagerPacket_GetKapMtlsStatus ¶
type ManagerPacket_GetKapMtlsStatus struct {
GetKapMtlsStatus *GetKAPMTLSStatusRequest `protobuf:"bytes,26,opt,name=get_kap_mtls_status,json=getKapMtlsStatus,proto3,oneof"`
}
type ManagerPacket_GetMetrics ¶
type ManagerPacket_GetMetrics struct {
GetMetrics *GetMetricsRequest `protobuf:"bytes,12,opt,name=get_metrics,json=getMetrics,proto3,oneof"`
}
type ManagerPacket_GetPackageStatus ¶
type ManagerPacket_GetPackageStatus struct {
GetPackageStatus *GetPackageStatusRequest `protobuf:"bytes,20,opt,name=get_package_status,json=getPackageStatus,proto3,oneof"`
}
type ManagerPacket_Gossip ¶
type ManagerPacket_Gossip struct {
Gossip *GossipRequest `protobuf:"bytes,22,opt,name=gossip,proto3,oneof"`
}
type ManagerPacket_HelloAck ¶
type ManagerPacket_HelloAck struct {
HelloAck *HelloAck `protobuf:"bytes,1,opt,name=hello_ack,json=helloAck,proto3,oneof"`
}
type ManagerPacket_InjectFault ¶
type ManagerPacket_InjectFault struct {
InjectFault *InjectFaultRequest `protobuf:"bytes,18,opt,name=inject_fault,json=injectFault,proto3,oneof"`
}
type ManagerPacket_Logout ¶
type ManagerPacket_Logout struct {
Logout *LogoutRequest `protobuf:"bytes,21,opt,name=logout,proto3,oneof"`
}
type ManagerPacket_Reboot ¶
type ManagerPacket_Reboot struct {
Reboot *RebootRequest `protobuf:"bytes,15,opt,name=reboot,proto3,oneof"`
}
type ManagerPacket_SetHealthy ¶
type ManagerPacket_SetHealthy struct {
SetHealthy *SetHealthyRequest `protobuf:"bytes,14,opt,name=set_healthy,json=setHealthy,proto3,oneof"`
}
type ManagerPacket_SetPluginSpecs ¶
type ManagerPacket_SetPluginSpecs struct {
SetPluginSpecs *SetPluginSpecsRequest `protobuf:"bytes,24,opt,name=set_plugin_specs,json=setPluginSpecs,proto3,oneof"`
}
type ManagerPacket_TriggerComponent ¶
type ManagerPacket_TriggerComponent struct {
TriggerComponent *TriggerComponentRequest `protobuf:"bytes,23,opt,name=trigger_component,json=triggerComponent,proto3,oneof"`
}
type ManagerPacket_Update ¶
type ManagerPacket_Update struct {
Update *UpdateRequest `protobuf:"bytes,13,opt,name=update,proto3,oneof"`
}
type ManagerPacket_UpdateConfig ¶
type ManagerPacket_UpdateConfig struct {
UpdateConfig *UpdateConfigRequest `protobuf:"bytes,16,opt,name=update_config,json=updateConfig,proto3,oneof"`
}
type ManagerPacket_UpdateKapMtlsCredentials ¶
type ManagerPacket_UpdateKapMtlsCredentials struct {
UpdateKapMtlsCredentials *UpdateKAPMTLSCredentialsRequest `protobuf:"bytes,27,opt,name=update_kap_mtls_credentials,json=updateKapMtlsCredentials,proto3,oneof"`
}
type ManagerPacket_UpdateToken ¶
type ManagerPacket_UpdateToken struct {
UpdateToken *UpdateTokenRequest `protobuf:"bytes,25,opt,name=update_token,json=updateToken,proto3,oneof"`
}
type Plugin ¶
type Plugin struct {
Steps []*PluginStep `protobuf:"bytes,1,rep,name=steps,proto3" json:"steps,omitempty"`
Parser *PluginOutputParser `protobuf:"bytes,2,opt,name=parser,proto3" json:"parser,omitempty"`
// contains filtered or unexported fields
}
func (*Plugin) Descriptor
deprecated
func (*Plugin) GetParser ¶
func (x *Plugin) GetParser() *PluginOutputParser
func (*Plugin) GetSteps ¶
func (x *Plugin) GetSteps() []*PluginStep
func (*Plugin) ProtoMessage ¶
func (*Plugin) ProtoMessage()
func (*Plugin) ProtoReflect ¶
func (x *Plugin) ProtoReflect() protoreflect.Message
type PluginJSONPath ¶
type PluginJSONPath struct {
Query string `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
Field string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
Expect *PluginMatchRule `protobuf:"bytes,3,opt,name=expect,proto3" json:"expect,omitempty"`
SuggestedActions map[string]*PluginMatchRule `` /* 183-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*PluginJSONPath) Descriptor
deprecated
func (*PluginJSONPath) Descriptor() ([]byte, []int)
Deprecated: Use PluginJSONPath.ProtoReflect.Descriptor instead.
func (*PluginJSONPath) GetExpect ¶
func (x *PluginJSONPath) GetExpect() *PluginMatchRule
func (*PluginJSONPath) GetField ¶
func (x *PluginJSONPath) GetField() string
func (*PluginJSONPath) GetQuery ¶
func (x *PluginJSONPath) GetQuery() string
func (*PluginJSONPath) GetSuggestedActions ¶
func (x *PluginJSONPath) GetSuggestedActions() map[string]*PluginMatchRule
func (*PluginJSONPath) ProtoMessage ¶
func (*PluginJSONPath) ProtoMessage()
func (*PluginJSONPath) ProtoReflect ¶
func (x *PluginJSONPath) ProtoReflect() protoreflect.Message
func (*PluginJSONPath) Reset ¶
func (x *PluginJSONPath) Reset()
func (*PluginJSONPath) String ¶
func (x *PluginJSONPath) String() string
type PluginMatchRule ¶
type PluginMatchRule struct {
Regex *string `protobuf:"bytes,1,opt,name=regex,proto3,oneof" json:"regex,omitempty"`
// contains filtered or unexported fields
}
func (*PluginMatchRule) Descriptor
deprecated
func (*PluginMatchRule) Descriptor() ([]byte, []int)
Deprecated: Use PluginMatchRule.ProtoReflect.Descriptor instead.
func (*PluginMatchRule) GetRegex ¶
func (x *PluginMatchRule) GetRegex() string
func (*PluginMatchRule) ProtoMessage ¶
func (*PluginMatchRule) ProtoMessage()
func (*PluginMatchRule) ProtoReflect ¶
func (x *PluginMatchRule) ProtoReflect() protoreflect.Message
func (*PluginMatchRule) Reset ¶
func (x *PluginMatchRule) Reset()
func (*PluginMatchRule) String ¶
func (x *PluginMatchRule) String() string
type PluginOutputParser ¶
type PluginOutputParser struct {
JsonPaths []*PluginJSONPath `protobuf:"bytes,1,rep,name=json_paths,json=jsonPaths,proto3" json:"json_paths,omitempty"`
LogPath string `protobuf:"bytes,2,opt,name=log_path,json=logPath,proto3" json:"log_path,omitempty"`
// contains filtered or unexported fields
}
func (*PluginOutputParser) Descriptor
deprecated
func (*PluginOutputParser) Descriptor() ([]byte, []int)
Deprecated: Use PluginOutputParser.ProtoReflect.Descriptor instead.
func (*PluginOutputParser) GetJsonPaths ¶
func (x *PluginOutputParser) GetJsonPaths() []*PluginJSONPath
func (*PluginOutputParser) GetLogPath ¶
func (x *PluginOutputParser) GetLogPath() string
func (*PluginOutputParser) ProtoMessage ¶
func (*PluginOutputParser) ProtoMessage()
func (*PluginOutputParser) ProtoReflect ¶
func (x *PluginOutputParser) ProtoReflect() protoreflect.Message
func (*PluginOutputParser) Reset ¶
func (x *PluginOutputParser) Reset()
func (*PluginOutputParser) String ¶
func (x *PluginOutputParser) String() string
type PluginSpec ¶
type PluginSpec struct {
PluginName string `protobuf:"bytes,1,opt,name=plugin_name,json=pluginName,proto3" json:"plugin_name,omitempty"`
PluginType string `protobuf:"bytes,2,opt,name=plugin_type,json=pluginType,proto3" json:"plugin_type,omitempty"`
ComponentList []string `protobuf:"bytes,3,rep,name=component_list,json=componentList,proto3" json:"component_list,omitempty"`
ComponentListFile string `protobuf:"bytes,4,opt,name=component_list_file,json=componentListFile,proto3" json:"component_list_file,omitempty"`
RunMode string `protobuf:"bytes,5,opt,name=run_mode,json=runMode,proto3" json:"run_mode,omitempty"`
Tags []string `protobuf:"bytes,6,rep,name=tags,proto3" json:"tags,omitempty"`
HealthStatePlugin *Plugin `protobuf:"bytes,7,opt,name=health_state_plugin,json=healthStatePlugin,proto3" json:"health_state_plugin,omitempty"`
TimeoutNanos int64 `protobuf:"varint,8,opt,name=timeout_nanos,json=timeoutNanos,proto3" json:"timeout_nanos,omitempty"`
IntervalNanos int64 `protobuf:"varint,9,opt,name=interval_nanos,json=intervalNanos,proto3" json:"interval_nanos,omitempty"`
// contains filtered or unexported fields
}
func (*PluginSpec) Descriptor
deprecated
func (*PluginSpec) Descriptor() ([]byte, []int)
Deprecated: Use PluginSpec.ProtoReflect.Descriptor instead.
func (*PluginSpec) GetComponentList ¶
func (x *PluginSpec) GetComponentList() []string
func (*PluginSpec) GetComponentListFile ¶
func (x *PluginSpec) GetComponentListFile() string
func (*PluginSpec) GetHealthStatePlugin ¶
func (x *PluginSpec) GetHealthStatePlugin() *Plugin
func (*PluginSpec) GetIntervalNanos ¶
func (x *PluginSpec) GetIntervalNanos() int64
func (*PluginSpec) GetPluginName ¶
func (x *PluginSpec) GetPluginName() string
func (*PluginSpec) GetPluginType ¶
func (x *PluginSpec) GetPluginType() string
func (*PluginSpec) GetRunMode ¶
func (x *PluginSpec) GetRunMode() string
func (*PluginSpec) GetTags ¶
func (x *PluginSpec) GetTags() []string
func (*PluginSpec) GetTimeoutNanos ¶
func (x *PluginSpec) GetTimeoutNanos() int64
func (*PluginSpec) ProtoMessage ¶
func (*PluginSpec) ProtoMessage()
func (*PluginSpec) ProtoReflect ¶
func (x *PluginSpec) ProtoReflect() protoreflect.Message
func (*PluginSpec) Reset ¶
func (x *PluginSpec) Reset()
func (*PluginSpec) String ¶
func (x *PluginSpec) String() string
type PluginStep ¶
type PluginStep struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
RunBashScript *BashScript `protobuf:"bytes,2,opt,name=run_bash_script,json=runBashScript,proto3" json:"run_bash_script,omitempty"`
// contains filtered or unexported fields
}
func (*PluginStep) Descriptor
deprecated
func (*PluginStep) Descriptor() ([]byte, []int)
Deprecated: Use PluginStep.ProtoReflect.Descriptor instead.
func (*PluginStep) GetName ¶
func (x *PluginStep) GetName() string
func (*PluginStep) GetRunBashScript ¶
func (x *PluginStep) GetRunBashScript() *BashScript
func (*PluginStep) ProtoMessage ¶
func (*PluginStep) ProtoMessage()
func (*PluginStep) ProtoReflect ¶
func (x *PluginStep) ProtoReflect() protoreflect.Message
func (*PluginStep) Reset ¶
func (x *PluginStep) Reset()
func (*PluginStep) String ¶
func (x *PluginStep) String() string
type RebootRequest ¶
type RebootRequest struct {
// contains filtered or unexported fields
}
func (*RebootRequest) Descriptor
deprecated
func (*RebootRequest) Descriptor() ([]byte, []int)
Deprecated: Use RebootRequest.ProtoReflect.Descriptor instead.
func (*RebootRequest) ProtoMessage ¶
func (*RebootRequest) ProtoMessage()
func (*RebootRequest) ProtoReflect ¶
func (x *RebootRequest) ProtoReflect() protoreflect.Message
func (*RebootRequest) Reset ¶
func (x *RebootRequest) Reset()
func (*RebootRequest) String ¶
func (x *RebootRequest) String() string
type Result ¶
type Result struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
PayloadJson []byte `protobuf:"bytes,2,opt,name=payload_json,json=payloadJson,proto3" json:"payload_json,omitempty"`
// contains filtered or unexported fields
}
func (*Result) Descriptor
deprecated
func (*Result) GetPayloadJson ¶
func (*Result) GetRequestId ¶
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
func (*Result) ProtoReflect ¶
func (x *Result) ProtoReflect() protoreflect.Message
type SessionServiceClient ¶
type SessionServiceClient interface {
Connect(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AgentPacket, ManagerPacket], error)
}
SessionServiceClient is the client API for SessionService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSessionServiceClient ¶
func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient
type SessionServiceServer ¶
type SessionServiceServer interface {
Connect(grpc.BidiStreamingServer[AgentPacket, ManagerPacket]) error
// contains filtered or unexported methods
}
SessionServiceServer is the server API for SessionService service. All implementations must embed UnimplementedSessionServiceServer for forward compatibility.
type SessionService_ConnectClient ¶
type SessionService_ConnectClient = grpc.BidiStreamingClient[AgentPacket, ManagerPacket]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SessionService_ConnectServer ¶
type SessionService_ConnectServer = grpc.BidiStreamingServer[AgentPacket, ManagerPacket]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type SetHealthyRequest ¶
type SetHealthyRequest struct {
Components []string `protobuf:"bytes,1,rep,name=components,proto3" json:"components,omitempty"`
SinceNanos int64 `protobuf:"varint,2,opt,name=since_nanos,json=sinceNanos,proto3" json:"since_nanos,omitempty"`
// contains filtered or unexported fields
}
func (*SetHealthyRequest) Descriptor
deprecated
func (*SetHealthyRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetHealthyRequest.ProtoReflect.Descriptor instead.
func (*SetHealthyRequest) GetComponents ¶
func (x *SetHealthyRequest) GetComponents() []string
func (*SetHealthyRequest) GetSinceNanos ¶
func (x *SetHealthyRequest) GetSinceNanos() int64
func (*SetHealthyRequest) ProtoMessage ¶
func (*SetHealthyRequest) ProtoMessage()
func (*SetHealthyRequest) ProtoReflect ¶
func (x *SetHealthyRequest) ProtoReflect() protoreflect.Message
func (*SetHealthyRequest) Reset ¶
func (x *SetHealthyRequest) Reset()
func (*SetHealthyRequest) String ¶
func (x *SetHealthyRequest) String() string
type SetPluginSpecsRequest ¶
type SetPluginSpecsRequest struct {
SpecsPresent bool `protobuf:"varint,1,opt,name=specs_present,json=specsPresent,proto3" json:"specs_present,omitempty"`
Specs []*PluginSpec `protobuf:"bytes,2,rep,name=specs,proto3" json:"specs,omitempty"`
// contains filtered or unexported fields
}
func (*SetPluginSpecsRequest) Descriptor
deprecated
func (*SetPluginSpecsRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetPluginSpecsRequest.ProtoReflect.Descriptor instead.
func (*SetPluginSpecsRequest) GetSpecs ¶
func (x *SetPluginSpecsRequest) GetSpecs() []*PluginSpec
func (*SetPluginSpecsRequest) GetSpecsPresent ¶
func (x *SetPluginSpecsRequest) GetSpecsPresent() bool
func (*SetPluginSpecsRequest) ProtoMessage ¶
func (*SetPluginSpecsRequest) ProtoMessage()
func (*SetPluginSpecsRequest) ProtoReflect ¶
func (x *SetPluginSpecsRequest) ProtoReflect() protoreflect.Message
func (*SetPluginSpecsRequest) Reset ¶
func (x *SetPluginSpecsRequest) Reset()
func (*SetPluginSpecsRequest) String ¶
func (x *SetPluginSpecsRequest) String() string
type TriggerComponentRequest ¶
type TriggerComponentRequest struct {
ComponentName string `protobuf:"bytes,1,opt,name=component_name,json=componentName,proto3" json:"component_name,omitempty"`
TagName string `protobuf:"bytes,2,opt,name=tag_name,json=tagName,proto3" json:"tag_name,omitempty"`
// contains filtered or unexported fields
}
func (*TriggerComponentRequest) Descriptor
deprecated
func (*TriggerComponentRequest) Descriptor() ([]byte, []int)
Deprecated: Use TriggerComponentRequest.ProtoReflect.Descriptor instead.
func (*TriggerComponentRequest) GetComponentName ¶
func (x *TriggerComponentRequest) GetComponentName() string
func (*TriggerComponentRequest) GetTagName ¶
func (x *TriggerComponentRequest) GetTagName() string
func (*TriggerComponentRequest) ProtoMessage ¶
func (*TriggerComponentRequest) ProtoMessage()
func (*TriggerComponentRequest) ProtoReflect ¶
func (x *TriggerComponentRequest) ProtoReflect() protoreflect.Message
func (*TriggerComponentRequest) Reset ¶
func (x *TriggerComponentRequest) Reset()
func (*TriggerComponentRequest) String ¶
func (x *TriggerComponentRequest) String() string
type UnimplementedSessionServiceServer ¶
type UnimplementedSessionServiceServer struct{}
UnimplementedSessionServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedSessionServiceServer) Connect ¶
func (UnimplementedSessionServiceServer) Connect(grpc.BidiStreamingServer[AgentPacket, ManagerPacket]) error
type UnsafeSessionServiceServer ¶
type UnsafeSessionServiceServer interface {
// contains filtered or unexported methods
}
UnsafeSessionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SessionServiceServer will result in compilation errors.
type UpdateConfigRequest ¶
type UpdateConfigRequest struct {
Values map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*UpdateConfigRequest) Descriptor
deprecated
func (*UpdateConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateConfigRequest.ProtoReflect.Descriptor instead.
func (*UpdateConfigRequest) GetValues ¶
func (x *UpdateConfigRequest) GetValues() map[string]string
func (*UpdateConfigRequest) ProtoMessage ¶
func (*UpdateConfigRequest) ProtoMessage()
func (*UpdateConfigRequest) ProtoReflect ¶
func (x *UpdateConfigRequest) ProtoReflect() protoreflect.Message
func (*UpdateConfigRequest) Reset ¶
func (x *UpdateConfigRequest) Reset()
func (*UpdateConfigRequest) String ¶
func (x *UpdateConfigRequest) String() string
type UpdateKAPMTLSCredentialsRequest ¶
type UpdateKAPMTLSCredentialsRequest struct {
CertificatePem []byte `protobuf:"bytes,1,opt,name=certificate_pem,json=certificatePem,proto3" json:"certificate_pem,omitempty"`
PrivateKeyPem []byte `protobuf:"bytes,2,opt,name=private_key_pem,json=privateKeyPem,proto3" json:"private_key_pem,omitempty"`
GatewayCaPem []byte `protobuf:"bytes,3,opt,name=gateway_ca_pem,json=gatewayCaPem,proto3" json:"gateway_ca_pem,omitempty"`
GatewayEndpoint string `protobuf:"bytes,4,opt,name=gateway_endpoint,json=gatewayEndpoint,proto3" json:"gateway_endpoint,omitempty"`
ServerName string `protobuf:"bytes,5,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
ClientCaFingerprint string `protobuf:"bytes,6,opt,name=client_ca_fingerprint,json=clientCaFingerprint,proto3" json:"client_ca_fingerprint,omitempty"`
GatewayCaFingerprint string `protobuf:"bytes,7,opt,name=gateway_ca_fingerprint,json=gatewayCaFingerprint,proto3" json:"gateway_ca_fingerprint,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateKAPMTLSCredentialsRequest) Descriptor
deprecated
func (*UpdateKAPMTLSCredentialsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateKAPMTLSCredentialsRequest.ProtoReflect.Descriptor instead.
func (*UpdateKAPMTLSCredentialsRequest) GetCertificatePem ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetCertificatePem() []byte
func (*UpdateKAPMTLSCredentialsRequest) GetClientCaFingerprint ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetClientCaFingerprint() string
func (*UpdateKAPMTLSCredentialsRequest) GetGatewayCaFingerprint ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetGatewayCaFingerprint() string
func (*UpdateKAPMTLSCredentialsRequest) GetGatewayCaPem ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetGatewayCaPem() []byte
func (*UpdateKAPMTLSCredentialsRequest) GetGatewayEndpoint ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetGatewayEndpoint() string
func (*UpdateKAPMTLSCredentialsRequest) GetPrivateKeyPem ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetPrivateKeyPem() []byte
func (*UpdateKAPMTLSCredentialsRequest) GetServerName ¶
func (x *UpdateKAPMTLSCredentialsRequest) GetServerName() string
func (*UpdateKAPMTLSCredentialsRequest) ProtoMessage ¶
func (*UpdateKAPMTLSCredentialsRequest) ProtoMessage()
func (*UpdateKAPMTLSCredentialsRequest) ProtoReflect ¶
func (x *UpdateKAPMTLSCredentialsRequest) ProtoReflect() protoreflect.Message
func (*UpdateKAPMTLSCredentialsRequest) Reset ¶
func (x *UpdateKAPMTLSCredentialsRequest) Reset()
func (*UpdateKAPMTLSCredentialsRequest) String ¶
func (x *UpdateKAPMTLSCredentialsRequest) String() string
type UpdateRequest ¶
type UpdateRequest struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
SinceNanos int64 `protobuf:"varint,2,opt,name=since_nanos,json=sinceNanos,proto3" json:"since_nanos,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetSinceNanos ¶
func (x *UpdateRequest) GetSinceNanos() int64
func (*UpdateRequest) GetVersion ¶
func (x *UpdateRequest) GetVersion() string
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateTokenRequest ¶
type UpdateTokenRequest struct {
Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateTokenRequest) Descriptor
deprecated
func (*UpdateTokenRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateTokenRequest.ProtoReflect.Descriptor instead.
func (*UpdateTokenRequest) GetToken ¶
func (x *UpdateTokenRequest) GetToken() string
func (*UpdateTokenRequest) ProtoMessage ¶
func (*UpdateTokenRequest) ProtoMessage()
func (*UpdateTokenRequest) ProtoReflect ¶
func (x *UpdateTokenRequest) ProtoReflect() protoreflect.Message
func (*UpdateTokenRequest) Reset ¶
func (x *UpdateTokenRequest) Reset()
func (*UpdateTokenRequest) String ¶
func (x *UpdateTokenRequest) String() string