Documentation ¶
Index ¶
- Variables
- type Address
- type Annotations
- type Annotations_Entry
- func (*Annotations_Entry) Descriptor() ([]byte, []int)deprecated
- func (x *Annotations_Entry) GetKey() string
- func (x *Annotations_Entry) GetValue() string
- func (*Annotations_Entry) ProtoMessage()
- func (x *Annotations_Entry) ProtoReflect() protoreflect.Message
- func (x *Annotations_Entry) Reset()
- func (x *Annotations_Entry) String() string
- type ClientInfoData
- func (*ClientInfoData) Descriptor() ([]byte, []int)deprecated
- func (x *ClientInfoData) GetLabels() []*Label
- func (x *ClientInfoData) GetServices() []*ClientInfoData_ServiceID
- func (*ClientInfoData) ProtoMessage()
- func (x *ClientInfoData) ProtoReflect() protoreflect.Message
- func (x *ClientInfoData) Reset()
- func (x *ClientInfoData) String() string
- type ClientInfoData_ServiceID
- func (*ClientInfoData_ServiceID) Descriptor() ([]byte, []int)deprecated
- func (x *ClientInfoData_ServiceID) GetName() string
- func (x *ClientInfoData_ServiceID) GetSignature() []byte
- func (*ClientInfoData_ServiceID) ProtoMessage()
- func (x *ClientInfoData_ServiceID) ProtoReflect() protoreflect.Message
- func (x *ClientInfoData_ServiceID) Reset()
- func (x *ClientInfoData_ServiceID) String() string
- type ClientServiceConfig
- func (*ClientServiceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ClientServiceConfig) GetConfig() *anypb.Any
- func (x *ClientServiceConfig) GetFactory() string
- func (x *ClientServiceConfig) GetName() string
- func (x *ClientServiceConfig) GetRequiredLabels() []*Label
- func (x *ClientServiceConfig) GetSignedTime() *timestamppb.Timestamp
- func (*ClientServiceConfig) ProtoMessage()
- func (x *ClientServiceConfig) ProtoReflect() protoreflect.Message
- func (x *ClientServiceConfig) Reset()
- func (x *ClientServiceConfig) String() string
- type ClientServiceConfigs
- func (*ClientServiceConfigs) Descriptor() ([]byte, []int)deprecated
- func (x *ClientServiceConfigs) GetConfig() []*ClientServiceConfig
- func (*ClientServiceConfigs) ProtoMessage()
- func (x *ClientServiceConfigs) ProtoReflect() protoreflect.Message
- func (x *ClientServiceConfigs) Reset()
- func (x *ClientServiceConfigs) String() string
- type ContactData
- func (*ContactData) Descriptor() ([]byte, []int)deprecated
- func (x *ContactData) GetAckIndex() uint64
- func (x *ContactData) GetAllowedMessages() map[string]uint64
- func (x *ContactData) GetClientClock() *timestamppb.Timestamp
- func (x *ContactData) GetDoneSending() bool
- func (x *ContactData) GetMessages() []*Message
- func (x *ContactData) GetSequencingNonce() uint64
- func (*ContactData) ProtoMessage()
- func (x *ContactData) ProtoReflect() protoreflect.Message
- func (x *ContactData) Reset()
- func (x *ContactData) String() string
- type DieRequest
- type EmptyMessage
- type Label
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetAnnotations() *Annotations
- func (x *Message) GetBackground() bool
- func (x *Message) GetCreationTime() *timestamppb.Timestamp
- func (x *Message) GetData() *anypb.Any
- func (x *Message) GetDestination() *Address
- func (x *Message) GetIsBlocklistedSource() bool
- func (x *Message) GetMessageId() []byte
- func (x *Message) GetMessageType() string
- func (x *Message) GetPriority() Message_Priority
- func (x *Message) GetResult() *MessageResult
- func (x *Message) GetSource() *Address
- func (x *Message) GetSourceMessageId() []byte
- func (x *Message) GetValidationInfo() *ValidationInfo
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type MessageAckData
- type MessageErrorData
- func (*MessageErrorData) Descriptor() ([]byte, []int)deprecated
- func (x *MessageErrorData) GetError() string
- func (x *MessageErrorData) GetMessageId() []byte
- func (*MessageErrorData) ProtoMessage()
- func (x *MessageErrorData) ProtoReflect() protoreflect.Message
- func (x *MessageErrorData) Reset()
- func (x *MessageErrorData) String() string
- type MessageResult
- func (*MessageResult) Descriptor() ([]byte, []int)deprecated
- func (x *MessageResult) GetFailed() bool
- func (x *MessageResult) GetFailedReason() string
- func (x *MessageResult) GetProcessedTime() *timestamppb.Timestamp
- func (*MessageResult) ProtoMessage()
- func (x *MessageResult) ProtoReflect() protoreflect.Message
- func (x *MessageResult) Reset()
- func (x *MessageResult) String() string
- type Message_Priority
- func (Message_Priority) Descriptor() protoreflect.EnumDescriptor
- func (x Message_Priority) Enum() *Message_Priority
- func (Message_Priority) EnumDescriptor() ([]byte, []int)deprecated
- func (x Message_Priority) Number() protoreflect.EnumNumber
- func (x Message_Priority) String() string
- func (Message_Priority) Type() protoreflect.EnumType
- type RemoveServiceData
- type RestartServiceRequest
- func (*RestartServiceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RestartServiceRequest) GetName() string
- func (*RestartServiceRequest) ProtoMessage()
- func (x *RestartServiceRequest) ProtoReflect() protoreflect.Message
- func (x *RestartServiceRequest) Reset()
- func (x *RestartServiceRequest) String() string
- type RevokedCertificateList
- func (*RevokedCertificateList) Descriptor() ([]byte, []int)deprecated
- func (x *RevokedCertificateList) GetSerials() [][]byte
- func (*RevokedCertificateList) ProtoMessage()
- func (x *RevokedCertificateList) ProtoReflect() protoreflect.Message
- func (x *RevokedCertificateList) Reset()
- func (x *RevokedCertificateList) String() string
- type Signature
- func (*Signature) Descriptor() ([]byte, []int)deprecated
- func (x *Signature) GetAlgorithm() int32
- func (x *Signature) GetCertificate() [][]byte
- func (x *Signature) GetSignature() []byte
- func (*Signature) ProtoMessage()
- func (x *Signature) ProtoReflect() protoreflect.Message
- func (x *Signature) Reset()
- func (x *Signature) String() string
- type SignedClientServiceConfig
- func (*SignedClientServiceConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SignedClientServiceConfig) GetServiceConfig() []byte
- func (x *SignedClientServiceConfig) GetSignature() []byte
- func (*SignedClientServiceConfig) ProtoMessage()
- func (x *SignedClientServiceConfig) ProtoReflect() protoreflect.Message
- func (x *SignedClientServiceConfig) Reset()
- func (x *SignedClientServiceConfig) String() string
- type ValidationInfo
- type WrappedContactData
- func (*WrappedContactData) Descriptor() ([]byte, []int)deprecated
- func (x *WrappedContactData) GetClientLabels() []string
- func (x *WrappedContactData) GetContactData() []byte
- func (x *WrappedContactData) GetSignatures() []*Signature
- func (*WrappedContactData) ProtoMessage()
- func (x *WrappedContactData) ProtoReflect() protoreflect.Message
- func (x *WrappedContactData) Reset()
- func (x *WrappedContactData) String() string
Constants ¶
This section is empty.
Variables ¶
var ( Message_Priority_name = map[int32]string{ 0: "MEDIUM", 1: "LOW", 2: "HIGH", } Message_Priority_value = map[string]int32{ "MEDIUM": 0, "LOW": 1, "HIGH": 2, } )
Enum value maps for Message_Priority.
var File_fleetspeak_src_common_proto_fleetspeak_common_proto protoreflect.FileDescriptor
var File_fleetspeak_src_common_proto_fleetspeak_system_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type Address ¶
type Address struct { // The client_id, if the address refers to a service on a client. If unset, // the address refers to a service on the server. ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"` // The name of the fleetspeak service which sent or should receive the // message. Required. ServiceName string `protobuf:"bytes,2,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // contains filtered or unexported fields }
An Address identifies the source or destination of a message.
func (*Address) Descriptor
deprecated
func (*Address) GetClientId ¶
func (*Address) GetServiceName ¶
func (*Address) ProtoMessage ¶
func (*Address) ProtoMessage()
func (*Address) ProtoReflect ¶
func (x *Address) ProtoReflect() protoreflect.Message
type Annotations ¶
type Annotations struct { Entries []*Annotations_Entry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*Annotations) Descriptor
deprecated
func (*Annotations) Descriptor() ([]byte, []int)
Deprecated: Use Annotations.ProtoReflect.Descriptor instead.
func (*Annotations) GetEntries ¶
func (x *Annotations) GetEntries() []*Annotations_Entry
func (*Annotations) ProtoMessage ¶
func (*Annotations) ProtoMessage()
func (*Annotations) ProtoReflect ¶
func (x *Annotations) ProtoReflect() protoreflect.Message
func (*Annotations) Reset ¶
func (x *Annotations) Reset()
func (*Annotations) String ¶
func (x *Annotations) String() string
type Annotations_Entry ¶
type Annotations_Entry struct { Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*Annotations_Entry) Descriptor
deprecated
func (*Annotations_Entry) Descriptor() ([]byte, []int)
Deprecated: Use Annotations_Entry.ProtoReflect.Descriptor instead.
func (*Annotations_Entry) GetKey ¶
func (x *Annotations_Entry) GetKey() string
func (*Annotations_Entry) GetValue ¶
func (x *Annotations_Entry) GetValue() string
func (*Annotations_Entry) ProtoMessage ¶
func (*Annotations_Entry) ProtoMessage()
func (*Annotations_Entry) ProtoReflect ¶
func (x *Annotations_Entry) ProtoReflect() protoreflect.Message
func (*Annotations_Entry) Reset ¶
func (x *Annotations_Entry) Reset()
func (*Annotations_Entry) String ¶
func (x *Annotations_Entry) String() string
type ClientInfoData ¶
type ClientInfoData struct { // Labels hardcoded by the client build, e.g. "client:Linux", // "client:<build-nr>", "client:canary". Labels []*Label `protobuf:"bytes,1,rep,name=labels,proto3" json:"labels,omitempty"` Services []*ClientInfoData_ServiceID `protobuf:"bytes,2,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
A ClientInfo message is sent from the client to the server on initial contact and after every configurate change.
func (*ClientInfoData) Descriptor
deprecated
func (*ClientInfoData) Descriptor() ([]byte, []int)
Deprecated: Use ClientInfoData.ProtoReflect.Descriptor instead.
func (*ClientInfoData) GetLabels ¶
func (x *ClientInfoData) GetLabels() []*Label
func (*ClientInfoData) GetServices ¶
func (x *ClientInfoData) GetServices() []*ClientInfoData_ServiceID
func (*ClientInfoData) ProtoMessage ¶
func (*ClientInfoData) ProtoMessage()
func (*ClientInfoData) ProtoReflect ¶
func (x *ClientInfoData) ProtoReflect() protoreflect.Message
func (*ClientInfoData) Reset ¶
func (x *ClientInfoData) Reset()
func (*ClientInfoData) String ¶
func (x *ClientInfoData) String() string
type ClientInfoData_ServiceID ¶
type ClientInfoData_ServiceID struct { // The name of the installed service. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The signature of the installed service, as provided in the AddServiceData // message which created the service. Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*ClientInfoData_ServiceID) Descriptor
deprecated
func (*ClientInfoData_ServiceID) Descriptor() ([]byte, []int)
Deprecated: Use ClientInfoData_ServiceID.ProtoReflect.Descriptor instead.
func (*ClientInfoData_ServiceID) GetName ¶
func (x *ClientInfoData_ServiceID) GetName() string
func (*ClientInfoData_ServiceID) GetSignature ¶
func (x *ClientInfoData_ServiceID) GetSignature() []byte
func (*ClientInfoData_ServiceID) ProtoMessage ¶
func (*ClientInfoData_ServiceID) ProtoMessage()
func (*ClientInfoData_ServiceID) ProtoReflect ¶
func (x *ClientInfoData_ServiceID) ProtoReflect() protoreflect.Message
func (*ClientInfoData_ServiceID) Reset ¶
func (x *ClientInfoData_ServiceID) Reset()
func (*ClientInfoData_ServiceID) String ¶
func (x *ClientInfoData_ServiceID) String() string
type ClientServiceConfig ¶
type ClientServiceConfig struct { // The name that the service will be known as. Primary use is to address // message to the service. the service names 'server' and 'client' are // reserved. Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // The name of the factory which will be used to generate the service. Factory string `protobuf:"bytes,2,opt,name=factory,proto3" json:"factory,omitempty"` // Additional configuration information for the factory to use when setting up // the service. The expected type depends upon the factory. Config *anypb.Any `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"` // The service will only be installed on clients with all of the listed // labels. Note that labels for the special 'client' service are checked on // the client. All other labels are only checked on the server. RequiredLabels []*Label `protobuf:"bytes,6,rep,name=required_labels,json=requiredLabels,proto3" json:"required_labels,omitempty"` // The time at which the service configuration was signed. Should be populated // by the signing tool when creating a SignedClientServiceConfig. SignedTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=signed_time,json=signedTime,proto3" json:"signed_time,omitempty"` // contains filtered or unexported fields }
func (*ClientServiceConfig) Descriptor
deprecated
func (*ClientServiceConfig) Descriptor() ([]byte, []int)
Deprecated: Use ClientServiceConfig.ProtoReflect.Descriptor instead.
func (*ClientServiceConfig) GetConfig ¶
func (x *ClientServiceConfig) GetConfig() *anypb.Any
func (*ClientServiceConfig) GetFactory ¶
func (x *ClientServiceConfig) GetFactory() string
func (*ClientServiceConfig) GetName ¶
func (x *ClientServiceConfig) GetName() string
func (*ClientServiceConfig) GetRequiredLabels ¶
func (x *ClientServiceConfig) GetRequiredLabels() []*Label
func (*ClientServiceConfig) GetSignedTime ¶
func (x *ClientServiceConfig) GetSignedTime() *timestamppb.Timestamp
func (*ClientServiceConfig) ProtoMessage ¶
func (*ClientServiceConfig) ProtoMessage()
func (*ClientServiceConfig) ProtoReflect ¶
func (x *ClientServiceConfig) ProtoReflect() protoreflect.Message
func (*ClientServiceConfig) Reset ¶
func (x *ClientServiceConfig) Reset()
func (*ClientServiceConfig) String ¶
func (x *ClientServiceConfig) String() string
type ClientServiceConfigs ¶
type ClientServiceConfigs struct { Config []*ClientServiceConfig `protobuf:"bytes,1,rep,name=config,proto3" json:"config,omitempty"` // contains filtered or unexported fields }
func (*ClientServiceConfigs) Descriptor
deprecated
func (*ClientServiceConfigs) Descriptor() ([]byte, []int)
Deprecated: Use ClientServiceConfigs.ProtoReflect.Descriptor instead.
func (*ClientServiceConfigs) GetConfig ¶
func (x *ClientServiceConfigs) GetConfig() []*ClientServiceConfig
func (*ClientServiceConfigs) ProtoMessage ¶
func (*ClientServiceConfigs) ProtoMessage()
func (*ClientServiceConfigs) ProtoReflect ¶
func (x *ClientServiceConfigs) ProtoReflect() protoreflect.Message
func (*ClientServiceConfigs) Reset ¶
func (x *ClientServiceConfigs) Reset()
func (*ClientServiceConfigs) String ¶
func (x *ClientServiceConfigs) String() string
type ContactData ¶
type ContactData struct { // During every contact, the server passes a random sequencing_nonce to the // client, and the client provides the sequencing_nonce to the server during // the next contact. SequencingNonce uint64 `protobuf:"varint,1,opt,name=sequencing_nonce,json=sequencingNonce,proto3" json:"sequencing_nonce,omitempty"` Messages []*Message `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"` // Records the client's current time setting, as of the creation of this // ContactData. Only set by the client. ClientClock *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=client_clock,json=clientClock,proto3" json:"client_clock,omitempty"` // If set, acknowledges receipt of a streamed WrappedContactData. This is used // for control purposes during streaming connections. AckIndex uint64 `protobuf:"varint,4,opt,name=ack_index,json=ackIndex,proto3" json:"ack_index,omitempty"` // If set, indicates that the connection is shutting down and no more data // will be sent. DoneSending bool `protobuf:"varint,5,opt,name=done_sending,json=doneSending,proto3" json:"done_sending,omitempty"` // Set by the client to indicate how many messages it is willing to accept for // each installed service. After the first exchange of an streaming // connection, it represents the number of additional messages that will be // accepted. AllowedMessages map[string]uint64 `` /* 172-byte string literal not displayed */ // contains filtered or unexported fields }
On every contact, the client and server exchange ContactData messages.
func (*ContactData) Descriptor
deprecated
func (*ContactData) Descriptor() ([]byte, []int)
Deprecated: Use ContactData.ProtoReflect.Descriptor instead.
func (*ContactData) GetAckIndex ¶
func (x *ContactData) GetAckIndex() uint64
func (*ContactData) GetAllowedMessages ¶
func (x *ContactData) GetAllowedMessages() map[string]uint64
func (*ContactData) GetClientClock ¶
func (x *ContactData) GetClientClock() *timestamppb.Timestamp
func (*ContactData) GetDoneSending ¶
func (x *ContactData) GetDoneSending() bool
func (*ContactData) GetMessages ¶
func (x *ContactData) GetMessages() []*Message
func (*ContactData) GetSequencingNonce ¶
func (x *ContactData) GetSequencingNonce() uint64
func (*ContactData) ProtoMessage ¶
func (*ContactData) ProtoMessage()
func (*ContactData) ProtoReflect ¶
func (x *ContactData) ProtoReflect() protoreflect.Message
func (*ContactData) Reset ¶
func (x *ContactData) Reset()
func (*ContactData) String ¶
func (x *ContactData) String() string
type DieRequest ¶
type DieRequest struct { Force bool `protobuf:"varint,1,opt,name=force,proto3" json:"force,omitempty"` // contains filtered or unexported fields }
func (*DieRequest) Descriptor
deprecated
func (*DieRequest) Descriptor() ([]byte, []int)
Deprecated: Use DieRequest.ProtoReflect.Descriptor instead.
func (*DieRequest) GetForce ¶
func (x *DieRequest) GetForce() bool
func (*DieRequest) ProtoMessage ¶
func (*DieRequest) ProtoMessage()
func (*DieRequest) ProtoReflect ¶
func (x *DieRequest) ProtoReflect() protoreflect.Message
func (*DieRequest) Reset ¶
func (x *DieRequest) Reset()
func (*DieRequest) String ¶
func (x *DieRequest) String() string
type EmptyMessage ¶
type EmptyMessage struct {
// contains filtered or unexported fields
}
An empty message, typically used as a trivial RPC response.
func (*EmptyMessage) Descriptor
deprecated
func (*EmptyMessage) Descriptor() ([]byte, []int)
Deprecated: Use EmptyMessage.ProtoReflect.Descriptor instead.
func (*EmptyMessage) ProtoMessage ¶
func (*EmptyMessage) ProtoMessage()
func (*EmptyMessage) ProtoReflect ¶
func (x *EmptyMessage) ProtoReflect() protoreflect.Message
func (*EmptyMessage) Reset ¶
func (x *EmptyMessage) Reset()
func (*EmptyMessage) String ¶
func (x *EmptyMessage) String() string
type Label ¶
type Label struct { // The service which set this label. ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"` // A free form tag choosen by the setting plugin. Label string `protobuf:"bytes,2,opt,name=label,proto3" json:"label,omitempty"` // contains filtered or unexported fields }
A Label is a tag assigned to a client by a plugin. Primary use is to limit broadcasts to specific clients.
func (*Label) Descriptor
deprecated
func (*Label) GetServiceName ¶
func (*Label) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) ProtoReflect ¶
func (x *Label) ProtoReflect() protoreflect.Message
type Message ¶
type Message struct { // A hash based on origin and origin_message_id. It is set by the fleetspeak // system on message intake and may be used for deduplication. MessageId []byte `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // The source of the messages. Required. Source *Address `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"` // Messages from blocklisted sources might still get delivered to the // server-side services. For example, due to high latency of these services // messages might get stored for later delivery before the source got // blocked. This attribute can be used by the receiver to filter out // messages from blocklisted sources. IsBlocklistedSource bool `protobuf:"varint,13,opt,name=is_blocklisted_source,json=isBlocklistedSource,proto3" json:"is_blocklisted_source,omitempty"` // An sequence of bytes set by the source in a way to uniquely identify the // message among all messages with the same origin. SourceMessageId []byte `protobuf:"bytes,3,opt,name=source_message_id,json=sourceMessageId,proto3" json:"source_message_id,omitempty"` // The destination of the message. Required. Destination *Address `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"` // The type of message. This field is mostly opaque to the Fleetspeak system, // but can be used for some statistics gathering. It is recommended that each // service define a static collection of short readable message types and // dispatch according to this when processing messages. e.g. "ResourceUsage", // "StdOutputData". MessageType string `protobuf:"bytes,5,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"` // Set when the message enters the FS system. CreationTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"` // The data associated with this request, accepted types are determined by the // service and may depend on message_type. Not typically stored after the // message is processed. Data *anypb.Any `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"` // Additional validation information, set by on the server by the (optional) // authorizer component based on WrappedContactData.validators, etc. ValidationInfo *ValidationInfo `protobuf:"bytes,8,opt,name=validation_info,json=validationInfo,proto3" json:"validation_info,omitempty"` // The result of processing the message. Set once processing has finished. Result *MessageResult `protobuf:"bytes,9,opt,name=result,proto3" json:"result,omitempty"` Priority Message_Priority `protobuf:"varint,10,opt,name=priority,proto3,enum=fleetspeak.Message_Priority" json:"priority,omitempty"` // A background message does not count as activity when deciding how fast to // poll the server. This flag should be set on messages which are unlikely to // trigger additional activity. Background bool `protobuf:"varint,11,opt,name=background,proto3" json:"background,omitempty"` // Optional debugging information provided by the originator of the // message. Fleetspeak stores this information along with the message for // later retrieval, but doesn't really do anything else with it. Annotations *Annotations `protobuf:"bytes,12,opt,name=annotations,proto3" json:"annotations,omitempty"` // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetAnnotations ¶
func (x *Message) GetAnnotations() *Annotations
func (*Message) GetBackground ¶
func (*Message) GetCreationTime ¶
func (x *Message) GetCreationTime() *timestamppb.Timestamp
func (*Message) GetDestination ¶
func (*Message) GetIsBlocklistedSource ¶
func (*Message) GetMessageId ¶
func (*Message) GetMessageType ¶
func (*Message) GetPriority ¶
func (x *Message) GetPriority() Message_Priority
func (*Message) GetResult ¶
func (x *Message) GetResult() *MessageResult
func (*Message) GetSourceMessageId ¶
func (*Message) GetValidationInfo ¶
func (x *Message) GetValidationInfo() *ValidationInfo
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type MessageAckData ¶
type MessageAckData struct { MessageIds [][]byte `protobuf:"bytes,1,rep,name=message_ids,json=messageIds,proto3" json:"message_ids,omitempty"` // contains filtered or unexported fields }
A MessageAck message is sent from the client to the server to acknowledge the successful receipt of one or more messages. Messages from the server to the client may be repeated until ack'd.
func (*MessageAckData) Descriptor
deprecated
func (*MessageAckData) Descriptor() ([]byte, []int)
Deprecated: Use MessageAckData.ProtoReflect.Descriptor instead.
func (*MessageAckData) GetMessageIds ¶
func (x *MessageAckData) GetMessageIds() [][]byte
func (*MessageAckData) ProtoMessage ¶
func (*MessageAckData) ProtoMessage()
func (*MessageAckData) ProtoReflect ¶
func (x *MessageAckData) ProtoReflect() protoreflect.Message
func (*MessageAckData) Reset ¶
func (x *MessageAckData) Reset()
func (*MessageAckData) String ¶
func (x *MessageAckData) String() string
type MessageErrorData ¶
type MessageErrorData struct { MessageId []byte `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"` // contains filtered or unexported fields }
A MessageError message is sent from the client to the server to indicate an permanent error in processing the message.
func (*MessageErrorData) Descriptor
deprecated
func (*MessageErrorData) Descriptor() ([]byte, []int)
Deprecated: Use MessageErrorData.ProtoReflect.Descriptor instead.
func (*MessageErrorData) GetError ¶
func (x *MessageErrorData) GetError() string
func (*MessageErrorData) GetMessageId ¶
func (x *MessageErrorData) GetMessageId() []byte
func (*MessageErrorData) ProtoMessage ¶
func (*MessageErrorData) ProtoMessage()
func (*MessageErrorData) ProtoReflect ¶
func (x *MessageErrorData) ProtoReflect() protoreflect.Message
func (*MessageErrorData) Reset ¶
func (x *MessageErrorData) Reset()
func (*MessageErrorData) String ¶
func (x *MessageErrorData) String() string
type MessageResult ¶
type MessageResult struct { // The time that processing finished. ProcessedTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=processed_time,json=processedTime,proto3" json:"processed_time,omitempty"` // Set when processing ended with a permanent failure. Failed bool `protobuf:"varint,3,opt,name=failed,proto3" json:"failed,omitempty"` // A human readable error message, normally set when failed is true. FailedReason string `protobuf:"bytes,4,opt,name=failed_reason,json=failedReason,proto3" json:"failed_reason,omitempty"` // contains filtered or unexported fields }
func (*MessageResult) Descriptor
deprecated
func (*MessageResult) Descriptor() ([]byte, []int)
Deprecated: Use MessageResult.ProtoReflect.Descriptor instead.
func (*MessageResult) GetFailed ¶
func (x *MessageResult) GetFailed() bool
func (*MessageResult) GetFailedReason ¶
func (x *MessageResult) GetFailedReason() string
func (*MessageResult) GetProcessedTime ¶
func (x *MessageResult) GetProcessedTime() *timestamppb.Timestamp
func (*MessageResult) ProtoMessage ¶
func (*MessageResult) ProtoMessage()
func (*MessageResult) ProtoReflect ¶
func (x *MessageResult) ProtoReflect() protoreflect.Message
func (*MessageResult) Reset ¶
func (x *MessageResult) Reset()
func (*MessageResult) String ¶
func (x *MessageResult) String() string
type Message_Priority ¶
type Message_Priority int32
The message priority. The primary effect is on the ordering of messages sent from the client to the server.
const ( Message_MEDIUM Message_Priority = 0 // Out of order, but results in a sensible default. Message_LOW Message_Priority = 1 Message_HIGH Message_Priority = 2 )
func (Message_Priority) Descriptor ¶
func (Message_Priority) Descriptor() protoreflect.EnumDescriptor
func (Message_Priority) Enum ¶
func (x Message_Priority) Enum() *Message_Priority
func (Message_Priority) EnumDescriptor
deprecated
func (Message_Priority) EnumDescriptor() ([]byte, []int)
Deprecated: Use Message_Priority.Descriptor instead.
func (Message_Priority) Number ¶
func (x Message_Priority) Number() protoreflect.EnumNumber
func (Message_Priority) String ¶
func (x Message_Priority) String() string
func (Message_Priority) Type ¶
func (Message_Priority) Type() protoreflect.EnumType
type RemoveServiceData ¶
type RemoveServiceData struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
A RemoveService message is sent from the server to the client to instruct the client to remove an existing service.
func (*RemoveServiceData) Descriptor
deprecated
func (*RemoveServiceData) Descriptor() ([]byte, []int)
Deprecated: Use RemoveServiceData.ProtoReflect.Descriptor instead.
func (*RemoveServiceData) GetName ¶
func (x *RemoveServiceData) GetName() string
func (*RemoveServiceData) ProtoMessage ¶
func (*RemoveServiceData) ProtoMessage()
func (*RemoveServiceData) ProtoReflect ¶
func (x *RemoveServiceData) ProtoReflect() protoreflect.Message
func (*RemoveServiceData) Reset ¶
func (x *RemoveServiceData) Reset()
func (*RemoveServiceData) String ¶
func (x *RemoveServiceData) String() string
type RestartServiceRequest ¶
type RestartServiceRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*RestartServiceRequest) Descriptor
deprecated
func (*RestartServiceRequest) Descriptor() ([]byte, []int)
Deprecated: Use RestartServiceRequest.ProtoReflect.Descriptor instead.
func (*RestartServiceRequest) GetName ¶
func (x *RestartServiceRequest) GetName() string
func (*RestartServiceRequest) ProtoMessage ¶
func (*RestartServiceRequest) ProtoMessage()
func (*RestartServiceRequest) ProtoReflect ¶
func (x *RestartServiceRequest) ProtoReflect() protoreflect.Message
func (*RestartServiceRequest) Reset ¶
func (x *RestartServiceRequest) Reset()
func (*RestartServiceRequest) String ¶
func (x *RestartServiceRequest) String() string
type RevokedCertificateList ¶
type RevokedCertificateList struct { Serials [][]byte `protobuf:"bytes,1,rep,name=serials,proto3" json:"serials,omitempty"` // contains filtered or unexported fields }
A list of serial numbers of certificates which should be considered revoked.
func (*RevokedCertificateList) Descriptor
deprecated
func (*RevokedCertificateList) Descriptor() ([]byte, []int)
Deprecated: Use RevokedCertificateList.ProtoReflect.Descriptor instead.
func (*RevokedCertificateList) GetSerials ¶
func (x *RevokedCertificateList) GetSerials() [][]byte
func (*RevokedCertificateList) ProtoMessage ¶
func (*RevokedCertificateList) ProtoMessage()
func (*RevokedCertificateList) ProtoReflect ¶
func (x *RevokedCertificateList) ProtoReflect() protoreflect.Message
func (*RevokedCertificateList) Reset ¶
func (x *RevokedCertificateList) Reset()
func (*RevokedCertificateList) String ¶
func (x *RevokedCertificateList) String() string
type Signature ¶
type Signature struct { // A chain of ASN.1 DER encoded x509 certificates. Certificate [][]byte `protobuf:"bytes,1,rep,name=certificate,proto3" json:"certificate,omitempty"` // Indicates the choice of signature algorithm, a constant from // https://golang.org/pkg/crypto/x509/#SignatureAlgorithm Algorithm int32 `protobuf:"varint,2,opt,name=algorithm,proto3" json:"algorithm,omitempty"` // A signature of the validated data, it should be consistent with both the // algorithm choice and the first element of the certificate chain. Signature []byte `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*Signature) Descriptor
deprecated
func (*Signature) GetAlgorithm ¶
func (*Signature) GetCertificate ¶
func (*Signature) GetSignature ¶
func (*Signature) ProtoMessage ¶
func (*Signature) ProtoMessage()
func (*Signature) ProtoReflect ¶
func (x *Signature) ProtoReflect() protoreflect.Message
type SignedClientServiceConfig ¶
type SignedClientServiceConfig struct { // A serialized ClientServiceConfig, defined below. ServiceConfig []byte `protobuf:"bytes,1,opt,name=service_config,json=serviceConfig,proto3" json:"service_config,omitempty"` // An RSASSA-PSS signature of service_config, made using a deployment key. Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
A SignedClientServiceConfig wraps a ClientServiceConfig with a signature, making it acceptable to clients.
func (*SignedClientServiceConfig) Descriptor
deprecated
func (*SignedClientServiceConfig) Descriptor() ([]byte, []int)
Deprecated: Use SignedClientServiceConfig.ProtoReflect.Descriptor instead.
func (*SignedClientServiceConfig) GetServiceConfig ¶
func (x *SignedClientServiceConfig) GetServiceConfig() []byte
func (*SignedClientServiceConfig) GetSignature ¶
func (x *SignedClientServiceConfig) GetSignature() []byte
func (*SignedClientServiceConfig) ProtoMessage ¶
func (*SignedClientServiceConfig) ProtoMessage()
func (*SignedClientServiceConfig) ProtoReflect ¶
func (x *SignedClientServiceConfig) ProtoReflect() protoreflect.Message
func (*SignedClientServiceConfig) Reset ¶
func (x *SignedClientServiceConfig) Reset()
func (*SignedClientServiceConfig) String ¶
func (x *SignedClientServiceConfig) String() string
type ValidationInfo ¶
type ValidationInfo struct { Tags map[string]string `` /* 149-byte string literal not displayed */ // contains filtered or unexported fields }
func (*ValidationInfo) Descriptor
deprecated
func (*ValidationInfo) Descriptor() ([]byte, []int)
Deprecated: Use ValidationInfo.ProtoReflect.Descriptor instead.
func (*ValidationInfo) GetTags ¶
func (x *ValidationInfo) GetTags() map[string]string
func (*ValidationInfo) ProtoMessage ¶
func (*ValidationInfo) ProtoMessage()
func (*ValidationInfo) ProtoReflect ¶
func (x *ValidationInfo) ProtoReflect() protoreflect.Message
func (*ValidationInfo) Reset ¶
func (x *ValidationInfo) Reset()
func (*ValidationInfo) String ¶
func (x *ValidationInfo) String() string
type WrappedContactData ¶
type WrappedContactData struct { ContactData []byte `protobuf:"bytes,1,opt,name=contact_data,json=contactData,proto3" json:"contact_data,omitempty"` // A serialized ContactData. Signatures []*Signature `protobuf:"bytes,2,rep,name=signatures,proto3" json:"signatures,omitempty"` // Optional extra signatures validating // contact_data. ClientLabels []string `protobuf:"bytes,3,rep,name=client_labels,json=clientLabels,proto3" json:"client_labels,omitempty"` // The labels that the client claims to // contains filtered or unexported fields }
A WrappedContactData is provided by the client to the server with every contact.
func (*WrappedContactData) Descriptor
deprecated
func (*WrappedContactData) Descriptor() ([]byte, []int)
Deprecated: Use WrappedContactData.ProtoReflect.Descriptor instead.
func (*WrappedContactData) GetClientLabels ¶
func (x *WrappedContactData) GetClientLabels() []string
func (*WrappedContactData) GetContactData ¶
func (x *WrappedContactData) GetContactData() []byte
func (*WrappedContactData) GetSignatures ¶
func (x *WrappedContactData) GetSignatures() []*Signature
func (*WrappedContactData) ProtoMessage ¶
func (*WrappedContactData) ProtoMessage()
func (*WrappedContactData) ProtoReflect ¶
func (x *WrappedContactData) ProtoReflect() protoreflect.Message
func (*WrappedContactData) Reset ¶
func (x *WrappedContactData) Reset()
func (*WrappedContactData) String ¶
func (x *WrappedContactData) String() string