fleetspeak_server

package
v0.1.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 5, 2024 License: Apache-2.0 Imports: 12 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "fleetspeak.server.Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateBroadcast",
			Handler:    _Admin_CreateBroadcast_Handler,
		},
		{
			MethodName: "ListActiveBroadcasts",
			Handler:    _Admin_ListActiveBroadcasts_Handler,
		},
		{
			MethodName: "ListClients",
			Handler:    _Admin_ListClients_Handler,
		},
		{
			MethodName: "ListClientContacts",
			Handler:    _Admin_ListClientContacts_Handler,
		},
		{
			MethodName: "GetMessageStatus",
			Handler:    _Admin_GetMessageStatus_Handler,
		},
		{
			MethodName: "InsertMessage",
			Handler:    _Admin_InsertMessage_Handler,
		},
		{
			MethodName: "DeletePendingMessages",
			Handler:    _Admin_DeletePendingMessages_Handler,
		},
		{
			MethodName: "GetPendingMessages",
			Handler:    _Admin_GetPendingMessages_Handler,
		},
		{
			MethodName: "GetPendingMessageCount",
			Handler:    _Admin_GetPendingMessageCount_Handler,
		},
		{
			MethodName: "StoreFile",
			Handler:    _Admin_StoreFile_Handler,
		},
		{
			MethodName: "KeepAlive",
			Handler:    _Admin_KeepAlive_Handler,
		},
		{
			MethodName: "BlacklistClient",
			Handler:    _Admin_BlacklistClient_Handler,
		},
		{
			MethodName: "FetchClientResourceUsageRecords",
			Handler:    _Admin_FetchClientResourceUsageRecords_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamClientIds",
			Handler:       _Admin_StreamClientIds_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "StreamClientContacts",
			Handler:       _Admin_StreamClientContacts_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "fleetspeak/src/server/proto/fleetspeak_server/admin.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_fleetspeak_src_server_proto_fleetspeak_server_admin_proto protoreflect.FileDescriptor
View Source 
var File_fleetspeak_src_server_proto_fleetspeak_server_broadcasts_proto protoreflect.FileDescriptor
View Source 
var File_fleetspeak_src_server_proto_fleetspeak_server_resource_proto protoreflect.FileDescriptor
View Source 
var File_fleetspeak_src_server_proto_fleetspeak_server_server_proto protoreflect.FileDescriptor
View Source 
var File_fleetspeak_src_server_proto_fleetspeak_server_services_proto protoreflect.FileDescriptor

Functions

func RegisterAdminServer 

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

Types

type AdminClient 

type AdminClient interface {
	// CreateBroadcast creates a FS broadcast, potentially sending a message to
	// many machines in the fleet.
	CreateBroadcast(ctx context.Context, in *CreateBroadcastRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
	// ListActiveBroadcasts lists the currently active FS broadcasts.
	ListActiveBroadcasts(ctx context.Context, in *ListActiveBroadcastsRequest, opts ...grpc.CallOption) (*ListActiveBroadcastsResponse, error)
	// ListClients lists the currently active FS clients.
	ListClients(ctx context.Context, in *ListClientsRequest, opts ...grpc.CallOption) (*ListClientsResponse, error)
	// StreamClientIds lists the currently active FS clients as a stream.
	StreamClientIds(ctx context.Context, in *StreamClientIdsRequest, opts ...grpc.CallOption) (Admin_StreamClientIdsClient, error)
	// ListClientContacts lists the contact history for a client.
	ListClientContacts(ctx context.Context, in *ListClientContactsRequest, opts ...grpc.CallOption) (*ListClientContactsResponse, error)
	// StreamClientContacts lists the contact history for a client as a stream.
	StreamClientContacts(ctx context.Context, in *StreamClientContactsRequest, opts ...grpc.CallOption) (Admin_StreamClientContactsClient, error)
	// GetMessageStatus retrieves the current status of a message.
	GetMessageStatus(ctx context.Context, in *GetMessageStatusRequest, opts ...grpc.CallOption) (*GetMessageStatusResponse, error)
	// InsertMessage inserts a message into the Fleetspeak system to be processed
	// by the server or delivered to a client.
	// TODO: Have this method return the message that is written to the
	// datastore (or at least the id).
	InsertMessage(ctx context.Context, in *fleetspeak.Message, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
	// DeletePendingMessages clears message queues for given clients.
	DeletePendingMessages(ctx context.Context, in *DeletePendingMessagesRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
	// Returns the pending messages for given clients.
	GetPendingMessages(ctx context.Context, in *GetPendingMessagesRequest, opts ...grpc.CallOption) (*GetPendingMessagesResponse, error)
	// Returns the number of pending messages for the given clients.
	GetPendingMessageCount(ctx context.Context, in *GetPendingMessageCountRequest, opts ...grpc.CallOption) (*GetPendingMessageCountResponse, error)
	// StoreFile inserts a file into the Fleetspeak system.
	StoreFile(ctx context.Context, in *StoreFileRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
	// KeepAlive does as little as possible.
	KeepAlive(ctx context.Context, in *fleetspeak.EmptyMessage, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
	// BlacklistClient marks a client_id as invalid, forcing all Fleetspeak
	// clients using it to rekey.
	BlacklistClient(ctx context.Context, in *BlacklistClientRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error)
	// FetchClientResourceUsageRecords returns all resource usage records for a
	// single client with a given limit on the number of records.
	FetchClientResourceUsageRecords(ctx context.Context, in *FetchClientResourceUsageRecordsRequest, opts ...grpc.CallOption) (*FetchClientResourceUsageRecordsResponse, error)
}

AdminClient is the client API for Admin 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 NewAdminClient 

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminServer 

type AdminServer interface {
	// CreateBroadcast creates a FS broadcast, potentially sending a message to
	// many machines in the fleet.
	CreateBroadcast(context.Context, *CreateBroadcastRequest) (*fleetspeak.EmptyMessage, error)
	// ListActiveBroadcasts lists the currently active FS broadcasts.
	ListActiveBroadcasts(context.Context, *ListActiveBroadcastsRequest) (*ListActiveBroadcastsResponse, error)
	// ListClients lists the currently active FS clients.
	ListClients(context.Context, *ListClientsRequest) (*ListClientsResponse, error)
	// StreamClientIds lists the currently active FS clients as a stream.
	StreamClientIds(*StreamClientIdsRequest, Admin_StreamClientIdsServer) error
	// ListClientContacts lists the contact history for a client.
	ListClientContacts(context.Context, *ListClientContactsRequest) (*ListClientContactsResponse, error)
	// StreamClientContacts lists the contact history for a client as a stream.
	StreamClientContacts(*StreamClientContactsRequest, Admin_StreamClientContactsServer) error
	// GetMessageStatus retrieves the current status of a message.
	GetMessageStatus(context.Context, *GetMessageStatusRequest) (*GetMessageStatusResponse, error)
	// InsertMessage inserts a message into the Fleetspeak system to be processed
	// by the server or delivered to a client.
	// TODO: Have this method return the message that is written to the
	// datastore (or at least the id).
	InsertMessage(context.Context, *fleetspeak.Message) (*fleetspeak.EmptyMessage, error)
	// DeletePendingMessages clears message queues for given clients.
	DeletePendingMessages(context.Context, *DeletePendingMessagesRequest) (*fleetspeak.EmptyMessage, error)
	// Returns the pending messages for given clients.
	GetPendingMessages(context.Context, *GetPendingMessagesRequest) (*GetPendingMessagesResponse, error)
	// Returns the number of pending messages for the given clients.
	GetPendingMessageCount(context.Context, *GetPendingMessageCountRequest) (*GetPendingMessageCountResponse, error)
	// StoreFile inserts a file into the Fleetspeak system.
	StoreFile(context.Context, *StoreFileRequest) (*fleetspeak.EmptyMessage, error)
	// KeepAlive does as little as possible.
	KeepAlive(context.Context, *fleetspeak.EmptyMessage) (*fleetspeak.EmptyMessage, error)
	// BlacklistClient marks a client_id as invalid, forcing all Fleetspeak
	// clients using it to rekey.
	BlacklistClient(context.Context, *BlacklistClientRequest) (*fleetspeak.EmptyMessage, error)
	// FetchClientResourceUsageRecords returns all resource usage records for a
	// single client with a given limit on the number of records.
	FetchClientResourceUsageRecords(context.Context, *FetchClientResourceUsageRecordsRequest) (*FetchClientResourceUsageRecordsResponse, error)
	// contains filtered or unexported methods
}

AdminServer is the server API for Admin service. All implementations must embed UnimplementedAdminServer for forward compatibility

type Admin_StreamClientContactsClient 

type Admin_StreamClientContactsClient interface {
	Recv() (*StreamClientContactsResponse, error)
	grpc.ClientStream
}

type Admin_StreamClientContactsServer 

type Admin_StreamClientContactsServer interface {
	Send(*StreamClientContactsResponse) error
	grpc.ServerStream
}

type Admin_StreamClientIdsClient 

type Admin_StreamClientIdsClient interface {
	Recv() (*StreamClientIdsResponse, error)
	grpc.ClientStream
}

type Admin_StreamClientIdsServer 

type Admin_StreamClientIdsServer interface {
	Send(*StreamClientIdsResponse) error
	grpc.ServerStream
}

type BlacklistClientRequest 

type BlacklistClientRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*BlacklistClientRequest) Descriptor deprecated 

func (*BlacklistClientRequest) Descriptor() ([]byte, []int)

Deprecated: Use BlacklistClientRequest.ProtoReflect.Descriptor instead.

func (*BlacklistClientRequest) GetClientId 

func (x *BlacklistClientRequest) GetClientId() []byte

func (*BlacklistClientRequest) ProtoMessage 

func (*BlacklistClientRequest) ProtoMessage()

func (*BlacklistClientRequest) ProtoReflect 

func (x *BlacklistClientRequest) ProtoReflect() protoreflect.Message

func (*BlacklistClientRequest) Reset 

func (x *BlacklistClientRequest) Reset()

func (*BlacklistClientRequest) String 

func (x *BlacklistClientRequest) String() string

type Broadcast 

type Broadcast struct {
	BroadcastId []byte `protobuf:"bytes,1,opt,name=broadcast_id,json=broadcastId,proto3" json:"broadcast_id,omitempty"`
	// The source of the broadcast, it should only be a server side service. The
	// destinations for the resulting broadcast messages will be different clients
	// with the same service name.
	Source      *fleetspeak.Address `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	MessageType string              `protobuf:"bytes,3,opt,name=message_type,json=messageType,proto3" json:"message_type,omitempty"`
	// A client will only be sent this broadcast if it has been marked with all of
	// the required labels.
	RequiredLabels []*fleetspeak.Label `protobuf:"bytes,4,rep,name=required_labels,json=requiredLabels,proto3" json:"required_labels,omitempty"`
	// A broadcast will stop being sent at this time.
	ExpirationTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	Data           *anypb.Any             `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

A Broadcast is a template to build messages to send to a number of machines.

func (*Broadcast) Descriptor deprecated 

func (*Broadcast) Descriptor() ([]byte, []int)

Deprecated: Use Broadcast.ProtoReflect.Descriptor instead.

func (*Broadcast) GetBroadcastId 

func (x *Broadcast) GetBroadcastId() []byte

func (*Broadcast) GetData 

func (x *Broadcast) GetData() *anypb.Any

func (*Broadcast) GetExpirationTime 

func (x *Broadcast) GetExpirationTime() *timestamppb.Timestamp

func (*Broadcast) GetMessageType 

func (x *Broadcast) GetMessageType() string

func (*Broadcast) GetRequiredLabels 

func (x *Broadcast) GetRequiredLabels() []*fleetspeak.Label

func (*Broadcast) GetSource 

func (x *Broadcast) GetSource() *fleetspeak.Address

func (*Broadcast) ProtoMessage 

func (*Broadcast) ProtoMessage()

func (*Broadcast) ProtoReflect 

func (x *Broadcast) ProtoReflect() protoreflect.Message

func (*Broadcast) Reset 

func (x *Broadcast) Reset()

func (*Broadcast) String 

func (x *Broadcast) String() string

type Client 

type Client struct {
	ClientId               []byte                 `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Labels                 []*fleetspeak.Label    `protobuf:"bytes,2,rep,name=labels,proto3" json:"labels,omitempty"`
	LastContactTime        *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_contact_time,json=lastContactTime,proto3" json:"last_contact_time,omitempty"`
	LastContactAddress     string                 `protobuf:"bytes,4,opt,name=last_contact_address,json=lastContactAddress,proto3" json:"last_contact_address,omitempty"`
	LastContactStreamingTo string                 `` /* 131-byte string literal not displayed */
	LastClock              *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_clock,json=lastClock,proto3" json:"last_clock,omitempty"`
	Blacklisted            bool                   `protobuf:"varint,6,opt,name=blacklisted,proto3" json:"blacklisted,omitempty"`
	// contains filtered or unexported fields
}

func (*Client) Descriptor deprecated 

func (*Client) Descriptor() ([]byte, []int)

Deprecated: Use Client.ProtoReflect.Descriptor instead.

func (*Client) GetBlacklisted 

func (x *Client) GetBlacklisted() bool

func (*Client) GetClientId 

func (x *Client) GetClientId() []byte

func (*Client) GetLabels 

func (x *Client) GetLabels() []*fleetspeak.Label

func (*Client) GetLastClock 

func (x *Client) GetLastClock() *timestamppb.Timestamp

func (*Client) GetLastContactAddress 

func (x *Client) GetLastContactAddress() string

func (*Client) GetLastContactStreamingTo 

func (x *Client) GetLastContactStreamingTo() string

func (*Client) GetLastContactTime 

func (x *Client) GetLastContactTime() *timestamppb.Timestamp

func (*Client) ProtoMessage 

func (*Client) ProtoMessage()

func (*Client) ProtoReflect 

func (x *Client) ProtoReflect() protoreflect.Message

func (*Client) Reset 

func (x *Client) Reset()

func (*Client) String 

func (x *Client) String() string

type ClientContact 

type ClientContact struct {
	SentNonce       uint64                 `protobuf:"fixed64,1,opt,name=sent_nonce,json=sentNonce,proto3" json:"sent_nonce,omitempty"`
	ReceivedNonce   uint64                 `protobuf:"fixed64,2,opt,name=received_nonce,json=receivedNonce,proto3" json:"received_nonce,omitempty"`
	ObservedAddress string                 `protobuf:"bytes,3,opt,name=observed_address,json=observedAddress,proto3" json:"observed_address,omitempty"`
	Timestamp       *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*ClientContact) Descriptor deprecated 

func (*ClientContact) Descriptor() ([]byte, []int)

Deprecated: Use ClientContact.ProtoReflect.Descriptor instead.

func (*ClientContact) GetObservedAddress 

func (x *ClientContact) GetObservedAddress() string

func (*ClientContact) GetReceivedNonce 

func (x *ClientContact) GetReceivedNonce() uint64

func (*ClientContact) GetSentNonce 

func (x *ClientContact) GetSentNonce() uint64

func (*ClientContact) GetTimestamp 

func (x *ClientContact) GetTimestamp() *timestamppb.Timestamp

func (*ClientContact) ProtoMessage 

func (*ClientContact) ProtoMessage()

func (*ClientContact) ProtoReflect 

func (x *ClientContact) ProtoReflect() protoreflect.Message

func (*ClientContact) Reset 

func (x *ClientContact) Reset()

func (*ClientContact) String 

func (x *ClientContact) String() string

type ClientResourceUsageRecord 

type ClientResourceUsageRecord struct {

	// Name of the client service that resource usage is charged/attributed to
	// e.g 'system' for the system Fleetspeak service, or the name of a daemon
	// service as specified in its config.
	Scope            string                 `protobuf:"bytes,1,opt,name=scope,proto3" json:"scope,omitempty"`
	Pid              int64                  `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	ProcessStartTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=process_start_time,json=processStartTime,proto3" json:"process_start_time,omitempty"`
	// When the resource-usage metrics were measured on the client.
	ClientTimestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=client_timestamp,json=clientTimestamp,proto3" json:"client_timestamp,omitempty"`
	// When the resource usage record was written to the data-store.
	ServerTimestamp *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=server_timestamp,json=serverTimestamp,proto3" json:"server_timestamp,omitempty"`
	// If true, indicates that the process has terminated, and that this is
	// the final resource-usage record for that process.
	ProcessTerminated bool `protobuf:"varint,12,opt,name=process_terminated,json=processTerminated,proto3" json:"process_terminated,omitempty"`
	// CPU-usage is in millis per second.
	MeanUserCpuRate       float32 `protobuf:"fixed32,6,opt,name=mean_user_cpu_rate,json=meanUserCpuRate,proto3" json:"mean_user_cpu_rate,omitempty"`
	MaxUserCpuRate        float32 `protobuf:"fixed32,7,opt,name=max_user_cpu_rate,json=maxUserCpuRate,proto3" json:"max_user_cpu_rate,omitempty"`
	MeanSystemCpuRate     float32 `protobuf:"fixed32,8,opt,name=mean_system_cpu_rate,json=meanSystemCpuRate,proto3" json:"mean_system_cpu_rate,omitempty"`
	MaxSystemCpuRate      float32 `protobuf:"fixed32,9,opt,name=max_system_cpu_rate,json=maxSystemCpuRate,proto3" json:"max_system_cpu_rate,omitempty"`
	MeanResidentMemoryMib int32   `` /* 130-byte string literal not displayed */
	MaxResidentMemoryMib  int32   `` /* 127-byte string literal not displayed */
	MeanNumFds            int32   `protobuf:"varint,13,opt,name=mean_num_fds,json=meanNumFds,proto3" json:"mean_num_fds,omitempty"`
	MaxNumFds             int32   `protobuf:"varint,14,opt,name=max_num_fds,json=maxNumFds,proto3" json:"max_num_fds,omitempty"`
	// contains filtered or unexported fields
}

Represents client resource-usage data in the data-store. Next id: 15

func (*ClientResourceUsageRecord) Descriptor deprecated 

func (*ClientResourceUsageRecord) Descriptor() ([]byte, []int)

Deprecated: Use ClientResourceUsageRecord.ProtoReflect.Descriptor instead.

func (*ClientResourceUsageRecord) GetClientTimestamp 

func (x *ClientResourceUsageRecord) GetClientTimestamp() *timestamppb.Timestamp

func (*ClientResourceUsageRecord) GetMaxNumFds 

func (x *ClientResourceUsageRecord) GetMaxNumFds() int32

func (*ClientResourceUsageRecord) GetMaxResidentMemoryMib 

func (x *ClientResourceUsageRecord) GetMaxResidentMemoryMib() int32

func (*ClientResourceUsageRecord) GetMaxSystemCpuRate 

func (x *ClientResourceUsageRecord) GetMaxSystemCpuRate() float32

func (*ClientResourceUsageRecord) GetMaxUserCpuRate 

func (x *ClientResourceUsageRecord) GetMaxUserCpuRate() float32

func (*ClientResourceUsageRecord) GetMeanNumFds 

func (x *ClientResourceUsageRecord) GetMeanNumFds() int32

func (*ClientResourceUsageRecord) GetMeanResidentMemoryMib 

func (x *ClientResourceUsageRecord) GetMeanResidentMemoryMib() int32

func (*ClientResourceUsageRecord) GetMeanSystemCpuRate 

func (x *ClientResourceUsageRecord) GetMeanSystemCpuRate() float32

func (*ClientResourceUsageRecord) GetMeanUserCpuRate 

func (x *ClientResourceUsageRecord) GetMeanUserCpuRate() float32

func (*ClientResourceUsageRecord) GetPid 

func (x *ClientResourceUsageRecord) GetPid() int64

func (*ClientResourceUsageRecord) GetProcessStartTime 

func (x *ClientResourceUsageRecord) GetProcessStartTime() *timestamppb.Timestamp

func (*ClientResourceUsageRecord) GetProcessTerminated 

func (x *ClientResourceUsageRecord) GetProcessTerminated() bool

func (*ClientResourceUsageRecord) GetScope 

func (x *ClientResourceUsageRecord) GetScope() string

func (*ClientResourceUsageRecord) GetServerTimestamp 

func (x *ClientResourceUsageRecord) GetServerTimestamp() *timestamppb.Timestamp

func (*ClientResourceUsageRecord) ProtoMessage 

func (*ClientResourceUsageRecord) ProtoMessage()

func (*ClientResourceUsageRecord) ProtoReflect 

func (x *ClientResourceUsageRecord) ProtoReflect() protoreflect.Message

func (*ClientResourceUsageRecord) Reset 

func (x *ClientResourceUsageRecord) Reset()

func (*ClientResourceUsageRecord) String 

func (x *ClientResourceUsageRecord) String() string

type CreateBroadcastRequest 

type CreateBroadcastRequest struct {
	Broadcast *Broadcast `protobuf:"bytes,1,opt,name=broadcast,proto3" json:"broadcast,omitempty"`
	Limit     uint64     `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBroadcastRequest) Descriptor deprecated 

func (*CreateBroadcastRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateBroadcastRequest.ProtoReflect.Descriptor instead.

func (*CreateBroadcastRequest) GetBroadcast 

func (x *CreateBroadcastRequest) GetBroadcast() *Broadcast

func (*CreateBroadcastRequest) GetLimit 

func (x *CreateBroadcastRequest) GetLimit() uint64

func (*CreateBroadcastRequest) ProtoMessage 

func (*CreateBroadcastRequest) ProtoMessage()

func (*CreateBroadcastRequest) ProtoReflect 

func (x *CreateBroadcastRequest) ProtoReflect() protoreflect.Message

func (*CreateBroadcastRequest) Reset 

func (x *CreateBroadcastRequest) Reset()

func (*CreateBroadcastRequest) String 

func (x *CreateBroadcastRequest) String() string

type DeletePendingMessagesRequest 

type DeletePendingMessagesRequest struct {
	ClientIds [][]byte `protobuf:"bytes,1,rep,name=client_ids,json=clientIds,proto3" json:"client_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*DeletePendingMessagesRequest) Descriptor deprecated 

func (*DeletePendingMessagesRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeletePendingMessagesRequest.ProtoReflect.Descriptor instead.

func (*DeletePendingMessagesRequest) GetClientIds 

func (x *DeletePendingMessagesRequest) GetClientIds() [][]byte

func (*DeletePendingMessagesRequest) ProtoMessage 

func (*DeletePendingMessagesRequest) ProtoMessage()

func (*DeletePendingMessagesRequest) ProtoReflect 

func (x *DeletePendingMessagesRequest) ProtoReflect() protoreflect.Message

func (*DeletePendingMessagesRequest) Reset 

func (x *DeletePendingMessagesRequest) Reset()

func (*DeletePendingMessagesRequest) String 

func (x *DeletePendingMessagesRequest) String() string

type FetchClientResourceUsageRecordsRequest 

type FetchClientResourceUsageRecordsRequest struct {
	ClientId       []byte                 `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	StartTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	EndTimestamp   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=end_timestamp,json=endTimestamp,proto3" json:"end_timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchClientResourceUsageRecordsRequest) Descriptor deprecated 

func (*FetchClientResourceUsageRecordsRequest) Descriptor() ([]byte, []int)

Deprecated: Use FetchClientResourceUsageRecordsRequest.ProtoReflect.Descriptor instead.

func (*FetchClientResourceUsageRecordsRequest) GetClientId 

func (x *FetchClientResourceUsageRecordsRequest) GetClientId() []byte

func (*FetchClientResourceUsageRecordsRequest) GetEndTimestamp 

func (x *FetchClientResourceUsageRecordsRequest) GetEndTimestamp() *timestamppb.Timestamp

func (*FetchClientResourceUsageRecordsRequest) GetStartTimestamp 

func (x *FetchClientResourceUsageRecordsRequest) GetStartTimestamp() *timestamppb.Timestamp

func (*FetchClientResourceUsageRecordsRequest) ProtoMessage 

func (*FetchClientResourceUsageRecordsRequest) ProtoMessage()

func (*FetchClientResourceUsageRecordsRequest) ProtoReflect 

func (x *FetchClientResourceUsageRecordsRequest) ProtoReflect() protoreflect.Message

func (*FetchClientResourceUsageRecordsRequest) Reset 

func (x *FetchClientResourceUsageRecordsRequest) Reset()

func (*FetchClientResourceUsageRecordsRequest) String 

func (x *FetchClientResourceUsageRecordsRequest) String() string

type FetchClientResourceUsageRecordsResponse 

type FetchClientResourceUsageRecordsResponse struct {
	Records []*ClientResourceUsageRecord `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchClientResourceUsageRecordsResponse) Descriptor deprecated 

func (*FetchClientResourceUsageRecordsResponse) Descriptor() ([]byte, []int)

Deprecated: Use FetchClientResourceUsageRecordsResponse.ProtoReflect.Descriptor instead.

func (*FetchClientResourceUsageRecordsResponse) GetRecords 

func (x *FetchClientResourceUsageRecordsResponse) GetRecords() []*ClientResourceUsageRecord

func (*FetchClientResourceUsageRecordsResponse) ProtoMessage 

func (*FetchClientResourceUsageRecordsResponse) ProtoMessage()

func (*FetchClientResourceUsageRecordsResponse) ProtoReflect 

func (x *FetchClientResourceUsageRecordsResponse) ProtoReflect() protoreflect.Message

func (*FetchClientResourceUsageRecordsResponse) Reset 

func (x *FetchClientResourceUsageRecordsResponse) Reset()

func (*FetchClientResourceUsageRecordsResponse) String 

func (x *FetchClientResourceUsageRecordsResponse) String() string

type GetMessageStatusRequest 

type GetMessageStatusRequest struct {
	MessageId []byte `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMessageStatusRequest) Descriptor deprecated 

func (*GetMessageStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetMessageStatusRequest.ProtoReflect.Descriptor instead.

func (*GetMessageStatusRequest) GetMessageId 

func (x *GetMessageStatusRequest) GetMessageId() []byte

func (*GetMessageStatusRequest) ProtoMessage 

func (*GetMessageStatusRequest) ProtoMessage()

func (*GetMessageStatusRequest) ProtoReflect 

func (x *GetMessageStatusRequest) ProtoReflect() protoreflect.Message

func (*GetMessageStatusRequest) Reset 

func (x *GetMessageStatusRequest) Reset()

func (*GetMessageStatusRequest) String 

func (x *GetMessageStatusRequest) String() string

type GetMessageStatusResponse 

type GetMessageStatusResponse struct {
	CreationTime *timestamppb.Timestamp    `protobuf:"bytes,1,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	Result       *fleetspeak.MessageResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*GetMessageStatusResponse) Descriptor deprecated 

func (*GetMessageStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetMessageStatusResponse.ProtoReflect.Descriptor instead.

func (*GetMessageStatusResponse) GetCreationTime 

func (x *GetMessageStatusResponse) GetCreationTime() *timestamppb.Timestamp

func (*GetMessageStatusResponse) GetResult 

func (x *GetMessageStatusResponse) GetResult() *fleetspeak.MessageResult

func (*GetMessageStatusResponse) ProtoMessage 

func (*GetMessageStatusResponse) ProtoMessage()

func (*GetMessageStatusResponse) ProtoReflect 

func (x *GetMessageStatusResponse) ProtoReflect() protoreflect.Message

func (*GetMessageStatusResponse) Reset 

func (x *GetMessageStatusResponse) Reset()

func (*GetMessageStatusResponse) String 

func (x *GetMessageStatusResponse) String() string

type GetPendingMessageCountRequest 

type GetPendingMessageCountRequest struct {
	ClientIds [][]byte `protobuf:"bytes,1,rep,name=client_ids,json=clientIds,proto3" json:"client_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPendingMessageCountRequest) Descriptor deprecated 

func (*GetPendingMessageCountRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPendingMessageCountRequest.ProtoReflect.Descriptor instead.

func (*GetPendingMessageCountRequest) GetClientIds 

func (x *GetPendingMessageCountRequest) GetClientIds() [][]byte

func (*GetPendingMessageCountRequest) ProtoMessage 

func (*GetPendingMessageCountRequest) ProtoMessage()

func (*GetPendingMessageCountRequest) ProtoReflect 

func (x *GetPendingMessageCountRequest) ProtoReflect() protoreflect.Message

func (*GetPendingMessageCountRequest) Reset 

func (x *GetPendingMessageCountRequest) Reset()

func (*GetPendingMessageCountRequest) String 

func (x *GetPendingMessageCountRequest) String() string

type GetPendingMessageCountResponse 

type GetPendingMessageCountResponse struct {
	Count uint64 `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPendingMessageCountResponse) Descriptor deprecated 

func (*GetPendingMessageCountResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPendingMessageCountResponse.ProtoReflect.Descriptor instead.

func (*GetPendingMessageCountResponse) GetCount 

func (x *GetPendingMessageCountResponse) GetCount() uint64

func (*GetPendingMessageCountResponse) ProtoMessage 

func (*GetPendingMessageCountResponse) ProtoMessage()

func (*GetPendingMessageCountResponse) ProtoReflect 

func (x *GetPendingMessageCountResponse) ProtoReflect() protoreflect.Message

func (*GetPendingMessageCountResponse) Reset 

func (x *GetPendingMessageCountResponse) Reset()

func (*GetPendingMessageCountResponse) String 

func (x *GetPendingMessageCountResponse) String() string

type GetPendingMessagesRequest 

type GetPendingMessagesRequest struct {
	ClientIds [][]byte `protobuf:"bytes,1,rep,name=client_ids,json=clientIds,proto3" json:"client_ids,omitempty"`
	Offset    uint64   `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit     uint64   `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	WantData  bool     `protobuf:"varint,4,opt,name=want_data,json=wantData,proto3" json:"want_data,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPendingMessagesRequest) Descriptor deprecated 

func (*GetPendingMessagesRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetPendingMessagesRequest.ProtoReflect.Descriptor instead.

func (*GetPendingMessagesRequest) GetClientIds 

func (x *GetPendingMessagesRequest) GetClientIds() [][]byte

func (*GetPendingMessagesRequest) GetLimit 

func (x *GetPendingMessagesRequest) GetLimit() uint64

func (*GetPendingMessagesRequest) GetOffset 

func (x *GetPendingMessagesRequest) GetOffset() uint64

func (*GetPendingMessagesRequest) GetWantData 

func (x *GetPendingMessagesRequest) GetWantData() bool

func (*GetPendingMessagesRequest) ProtoMessage 

func (*GetPendingMessagesRequest) ProtoMessage()

func (*GetPendingMessagesRequest) ProtoReflect 

func (x *GetPendingMessagesRequest) ProtoReflect() protoreflect.Message

func (*GetPendingMessagesRequest) Reset 

func (x *GetPendingMessagesRequest) Reset()

func (*GetPendingMessagesRequest) String 

func (x *GetPendingMessagesRequest) String() string

type GetPendingMessagesResponse 

type GetPendingMessagesResponse struct {
	Messages []*fleetspeak.Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPendingMessagesResponse) Descriptor deprecated 

func (*GetPendingMessagesResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetPendingMessagesResponse.ProtoReflect.Descriptor instead.

func (*GetPendingMessagesResponse) GetMessages 

func (x *GetPendingMessagesResponse) GetMessages() []*fleetspeak.Message

func (*GetPendingMessagesResponse) ProtoMessage 

func (*GetPendingMessagesResponse) ProtoMessage()

func (*GetPendingMessagesResponse) ProtoReflect 

func (x *GetPendingMessagesResponse) ProtoReflect() protoreflect.Message

func (*GetPendingMessagesResponse) Reset 

func (x *GetPendingMessagesResponse) Reset()

func (*GetPendingMessagesResponse) String 

func (x *GetPendingMessagesResponse) String() string

type ListActiveBroadcastsRequest 

type ListActiveBroadcastsRequest struct {

	// If set, only return broadcasts with the given service_name.
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ListActiveBroadcastsRequest) Descriptor deprecated 

func (*ListActiveBroadcastsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListActiveBroadcastsRequest.ProtoReflect.Descriptor instead.

func (*ListActiveBroadcastsRequest) GetServiceName 

func (x *ListActiveBroadcastsRequest) GetServiceName() string

func (*ListActiveBroadcastsRequest) ProtoMessage 

func (*ListActiveBroadcastsRequest) ProtoMessage()

func (*ListActiveBroadcastsRequest) ProtoReflect 

func (x *ListActiveBroadcastsRequest) ProtoReflect() protoreflect.Message

func (*ListActiveBroadcastsRequest) Reset 

func (x *ListActiveBroadcastsRequest) Reset()

func (*ListActiveBroadcastsRequest) String 

func (x *ListActiveBroadcastsRequest) String() string

type ListActiveBroadcastsResponse 

type ListActiveBroadcastsResponse struct {
	Broadcasts []*Broadcast `protobuf:"bytes,1,rep,name=broadcasts,proto3" json:"broadcasts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListActiveBroadcastsResponse) Descriptor deprecated 

func (*ListActiveBroadcastsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListActiveBroadcastsResponse.ProtoReflect.Descriptor instead.

func (*ListActiveBroadcastsResponse) GetBroadcasts 

func (x *ListActiveBroadcastsResponse) GetBroadcasts() []*Broadcast

func (*ListActiveBroadcastsResponse) ProtoMessage 

func (*ListActiveBroadcastsResponse) ProtoMessage()

func (*ListActiveBroadcastsResponse) ProtoReflect 

func (x *ListActiveBroadcastsResponse) ProtoReflect() protoreflect.Message

func (*ListActiveBroadcastsResponse) Reset 

func (x *ListActiveBroadcastsResponse) Reset()

func (*ListActiveBroadcastsResponse) String 

func (x *ListActiveBroadcastsResponse) String() string

type ListClientContactsRequest 

type ListClientContactsRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientContactsRequest) Descriptor deprecated 

func (*ListClientContactsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClientContactsRequest.ProtoReflect.Descriptor instead.

func (*ListClientContactsRequest) GetClientId 

func (x *ListClientContactsRequest) GetClientId() []byte

func (*ListClientContactsRequest) ProtoMessage 

func (*ListClientContactsRequest) ProtoMessage()

func (*ListClientContactsRequest) ProtoReflect 

func (x *ListClientContactsRequest) ProtoReflect() protoreflect.Message

func (*ListClientContactsRequest) Reset 

func (x *ListClientContactsRequest) Reset()

func (*ListClientContactsRequest) String 

func (x *ListClientContactsRequest) String() string

type ListClientContactsResponse 

type ListClientContactsResponse struct {
	Contacts []*ClientContact `protobuf:"bytes,1,rep,name=contacts,proto3" json:"contacts,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientContactsResponse) Descriptor deprecated 

func (*ListClientContactsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListClientContactsResponse.ProtoReflect.Descriptor instead.

func (*ListClientContactsResponse) GetContacts 

func (x *ListClientContactsResponse) GetContacts() []*ClientContact

func (*ListClientContactsResponse) ProtoMessage 

func (*ListClientContactsResponse) ProtoMessage()

func (*ListClientContactsResponse) ProtoReflect 

func (x *ListClientContactsResponse) ProtoReflect() protoreflect.Message

func (*ListClientContactsResponse) Reset 

func (x *ListClientContactsResponse) Reset()

func (*ListClientContactsResponse) String 

func (x *ListClientContactsResponse) String() string

type ListClientsRequest 

type ListClientsRequest struct {

	// If non-empty, restricts results to the listed client_ids. If empty, all
	// clients known to the system will be listed.
	ClientIds [][]byte `protobuf:"bytes,1,rep,name=client_ids,json=clientIds,proto3" json:"client_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientsRequest) Descriptor deprecated 

func (*ListClientsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListClientsRequest.ProtoReflect.Descriptor instead.

func (*ListClientsRequest) GetClientIds 

func (x *ListClientsRequest) GetClientIds() [][]byte

func (*ListClientsRequest) ProtoMessage 

func (*ListClientsRequest) ProtoMessage()

func (*ListClientsRequest) ProtoReflect 

func (x *ListClientsRequest) ProtoReflect() protoreflect.Message

func (*ListClientsRequest) Reset 

func (x *ListClientsRequest) Reset()

func (*ListClientsRequest) String 

func (x *ListClientsRequest) String() string

type ListClientsResponse 

type ListClientsResponse struct {
	Clients []*Client `protobuf:"bytes,1,rep,name=clients,proto3" json:"clients,omitempty"`
	// contains filtered or unexported fields
}

func (*ListClientsResponse) Descriptor deprecated 

func (*ListClientsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListClientsResponse.ProtoReflect.Descriptor instead.

func (*ListClientsResponse) GetClients 

func (x *ListClientsResponse) GetClients() []*Client

func (*ListClientsResponse) ProtoMessage 

func (*ListClientsResponse) ProtoMessage()

func (*ListClientsResponse) ProtoReflect 

func (x *ListClientsResponse) ProtoReflect() protoreflect.Message

func (*ListClientsResponse) Reset 

func (x *ListClientsResponse) Reset()

func (*ListClientsResponse) String 

func (x *ListClientsResponse) String() string

type ServerConfig 

type ServerConfig struct {

	// The collection of services that this server should include.
	Services []*ServiceConfig `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// The approximate time to wait between checking for new broadcasts. If unset,
	// a default of 1 minute is used.
	BroadcastPollTime *durationpb.Duration `protobuf:"bytes,2,opt,name=broadcast_poll_time,json=broadcastPollTime,proto3" json:"broadcast_poll_time,omitempty"`
	// contains filtered or unexported fields
}

Describes a server's configuration. If unset, all values default to values reasonable for a unit test or small installation. Larger installations may need to tune these.

func (*ServerConfig) Descriptor deprecated 

func (*ServerConfig) Descriptor() ([]byte, []int)

Deprecated: Use ServerConfig.ProtoReflect.Descriptor instead.

func (*ServerConfig) GetBroadcastPollTime 

func (x *ServerConfig) GetBroadcastPollTime() *durationpb.Duration

func (*ServerConfig) GetServices 

func (x *ServerConfig) GetServices() []*ServiceConfig

func (*ServerConfig) ProtoMessage 

func (*ServerConfig) ProtoMessage()

func (*ServerConfig) ProtoReflect 

func (x *ServerConfig) ProtoReflect() protoreflect.Message

func (*ServerConfig) Reset 

func (x *ServerConfig) Reset()

func (*ServerConfig) String 

func (x *ServerConfig) String() string

type ServiceConfig 

type ServiceConfig struct {

	// The name that the service will be known as. Primary use is to address
	// messages 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"`
	// The maximum number of simultaneous calls to the service's ProcessMessage
	// method. If unset, defaults to 100.
	MaxParallelism uint32 `protobuf:"varint,3,opt,name=max_parallelism,json=maxParallelism,proto3" json:"max_parallelism,omitempty"`
	// Additional configuration information for the factory to use when setting up
	// the service. The allowed type depends upon the factory.
	Config *anypb.Any `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

A ServiceConfig describes how the server should configure a 'service', which is a module that sends and processes messages.

func (*ServiceConfig) Descriptor deprecated 

func (*ServiceConfig) Descriptor() ([]byte, []int)

Deprecated: Use ServiceConfig.ProtoReflect.Descriptor instead.

func (*ServiceConfig) GetConfig 

func (x *ServiceConfig) GetConfig() *anypb.Any

func (*ServiceConfig) GetFactory 

func (x *ServiceConfig) GetFactory() string

func (*ServiceConfig) GetMaxParallelism 

func (x *ServiceConfig) GetMaxParallelism() uint32

func (*ServiceConfig) GetName 

func (x *ServiceConfig) GetName() string

func (*ServiceConfig) ProtoMessage 

func (*ServiceConfig) ProtoMessage()

func (*ServiceConfig) ProtoReflect 

func (x *ServiceConfig) ProtoReflect() protoreflect.Message

func (*ServiceConfig) Reset 

func (x *ServiceConfig) Reset()

func (*ServiceConfig) String 

func (x *ServiceConfig) String() string

type StoreFileRequest 

type StoreFileRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	FileName    string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Data        []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreFileRequest) Descriptor deprecated 

func (*StoreFileRequest) Descriptor() ([]byte, []int)

Deprecated: Use StoreFileRequest.ProtoReflect.Descriptor instead.

func (*StoreFileRequest) GetData 

func (x *StoreFileRequest) GetData() []byte

func (*StoreFileRequest) GetFileName 

func (x *StoreFileRequest) GetFileName() string

func (*StoreFileRequest) GetServiceName 

func (x *StoreFileRequest) GetServiceName() string

func (*StoreFileRequest) ProtoMessage 

func (*StoreFileRequest) ProtoMessage()

func (*StoreFileRequest) ProtoReflect 

func (x *StoreFileRequest) ProtoReflect() protoreflect.Message

func (*StoreFileRequest) Reset 

func (x *StoreFileRequest) Reset()

func (*StoreFileRequest) String 

func (x *StoreFileRequest) String() string

type StreamClientContactsRequest 

type StreamClientContactsRequest struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamClientContactsRequest) Descriptor deprecated 

func (*StreamClientContactsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamClientContactsRequest.ProtoReflect.Descriptor instead.

func (*StreamClientContactsRequest) GetClientId 

func (x *StreamClientContactsRequest) GetClientId() []byte

func (*StreamClientContactsRequest) ProtoMessage 

func (*StreamClientContactsRequest) ProtoMessage()

func (*StreamClientContactsRequest) ProtoReflect 

func (x *StreamClientContactsRequest) ProtoReflect() protoreflect.Message

func (*StreamClientContactsRequest) Reset 

func (x *StreamClientContactsRequest) Reset()

func (*StreamClientContactsRequest) String 

func (x *StreamClientContactsRequest) String() string

type StreamClientContactsResponse 

type StreamClientContactsResponse struct {
	Contact *ClientContact `protobuf:"bytes,1,opt,name=contact,proto3" json:"contact,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamClientContactsResponse) Descriptor deprecated 

func (*StreamClientContactsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamClientContactsResponse.ProtoReflect.Descriptor instead.

func (*StreamClientContactsResponse) GetContact 

func (x *StreamClientContactsResponse) GetContact() *ClientContact

func (*StreamClientContactsResponse) ProtoMessage 

func (*StreamClientContactsResponse) ProtoMessage()

func (*StreamClientContactsResponse) ProtoReflect 

func (x *StreamClientContactsResponse) ProtoReflect() protoreflect.Message

func (*StreamClientContactsResponse) Reset 

func (x *StreamClientContactsResponse) Reset()

func (*StreamClientContactsResponse) String 

func (x *StreamClientContactsResponse) String() string

type StreamClientIdsRequest 

type StreamClientIdsRequest struct {
	IncludeBlacklisted bool                   `protobuf:"varint,1,opt,name=include_blacklisted,json=includeBlacklisted,proto3" json:"include_blacklisted,omitempty"`
	LastContactAfter   *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_contact_after,json=lastContactAfter,proto3" json:"last_contact_after,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamClientIdsRequest) Descriptor deprecated 

func (*StreamClientIdsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StreamClientIdsRequest.ProtoReflect.Descriptor instead.

func (*StreamClientIdsRequest) GetIncludeBlacklisted 

func (x *StreamClientIdsRequest) GetIncludeBlacklisted() bool

func (*StreamClientIdsRequest) GetLastContactAfter 

func (x *StreamClientIdsRequest) GetLastContactAfter() *timestamppb.Timestamp

func (*StreamClientIdsRequest) ProtoMessage 

func (*StreamClientIdsRequest) ProtoMessage()

func (*StreamClientIdsRequest) ProtoReflect 

func (x *StreamClientIdsRequest) ProtoReflect() protoreflect.Message

func (*StreamClientIdsRequest) Reset 

func (x *StreamClientIdsRequest) Reset()

func (*StreamClientIdsRequest) String 

func (x *StreamClientIdsRequest) String() string

type StreamClientIdsResponse 

type StreamClientIdsResponse struct {
	ClientId []byte `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamClientIdsResponse) Descriptor deprecated 

func (*StreamClientIdsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StreamClientIdsResponse.ProtoReflect.Descriptor instead.

func (*StreamClientIdsResponse) GetClientId 

func (x *StreamClientIdsResponse) GetClientId() []byte

func (*StreamClientIdsResponse) ProtoMessage 

func (*StreamClientIdsResponse) ProtoMessage()

func (*StreamClientIdsResponse) ProtoReflect 

func (x *StreamClientIdsResponse) ProtoReflect() protoreflect.Message

func (*StreamClientIdsResponse) Reset 

func (x *StreamClientIdsResponse) Reset()

func (*StreamClientIdsResponse) String 

func (x *StreamClientIdsResponse) String() string

type UnimplementedAdminServer 

type UnimplementedAdminServer struct {
}

UnimplementedAdminServer must be embedded to have forward compatible implementations.

func (UnimplementedAdminServer) BlacklistClient 

func (UnimplementedAdminServer) BlacklistClient(context.Context, *BlacklistClientRequest) (*fleetspeak.EmptyMessage, error)

func (UnimplementedAdminServer) CreateBroadcast 

func (UnimplementedAdminServer) CreateBroadcast(context.Context, *CreateBroadcastRequest) (*fleetspeak.EmptyMessage, error)

func (UnimplementedAdminServer) DeletePendingMessages 

func (UnimplementedAdminServer) DeletePendingMessages(context.Context, *DeletePendingMessagesRequest) (*fleetspeak.EmptyMessage, error)

func (UnimplementedAdminServer) FetchClientResourceUsageRecords 

func (UnimplementedAdminServer) FetchClientResourceUsageRecords(context.Context, *FetchClientResourceUsageRecordsRequest) (*FetchClientResourceUsageRecordsResponse, error)

func (UnimplementedAdminServer) GetMessageStatus 

func (UnimplementedAdminServer) GetMessageStatus(context.Context, *GetMessageStatusRequest) (*GetMessageStatusResponse, error)

func (UnimplementedAdminServer) GetPendingMessageCount 

func (UnimplementedAdminServer) GetPendingMessageCount(context.Context, *GetPendingMessageCountRequest) (*GetPendingMessageCountResponse, error)

func (UnimplementedAdminServer) GetPendingMessages 

func (UnimplementedAdminServer) GetPendingMessages(context.Context, *GetPendingMessagesRequest) (*GetPendingMessagesResponse, error)

func (UnimplementedAdminServer) InsertMessage 

func (UnimplementedAdminServer) InsertMessage(context.Context, *fleetspeak.Message) (*fleetspeak.EmptyMessage, error)

func (UnimplementedAdminServer) KeepAlive 

func (UnimplementedAdminServer) KeepAlive(context.Context, *fleetspeak.EmptyMessage) (*fleetspeak.EmptyMessage, error)

func (UnimplementedAdminServer) ListActiveBroadcasts 

func (UnimplementedAdminServer) ListActiveBroadcasts(context.Context, *ListActiveBroadcastsRequest) (*ListActiveBroadcastsResponse, error)

func (UnimplementedAdminServer) ListClientContacts 

func (UnimplementedAdminServer) ListClientContacts(context.Context, *ListClientContactsRequest) (*ListClientContactsResponse, error)

func (UnimplementedAdminServer) ListClients 

func (UnimplementedAdminServer) ListClients(context.Context, *ListClientsRequest) (*ListClientsResponse, error)

func (UnimplementedAdminServer) StoreFile 

func (UnimplementedAdminServer) StoreFile(context.Context, *StoreFileRequest) (*fleetspeak.EmptyMessage, error)

func (UnimplementedAdminServer) StreamClientContacts 

func (UnimplementedAdminServer) StreamClientContacts(*StreamClientContactsRequest, Admin_StreamClientContactsServer) error

func (UnimplementedAdminServer) StreamClientIds 

func (UnimplementedAdminServer) StreamClientIds(*StreamClientIdsRequest, Admin_StreamClientIdsServer) error

type UnsafeAdminServer 

type UnsafeAdminServer interface {
	// contains filtered or unexported methods
}

UnsafeAdminServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AdminServer will result in compilation errors.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.