Versions in this module Expand all Collapse all v0 v0.1.14 Apr 23, 2024 v0.1.13 Mar 5, 2024 Changes in this version + var Admin_ServiceDesc = grpc.ServiceDesc + var File_fleetspeak_src_server_proto_fleetspeak_server_admin_proto protoreflect.FileDescriptor + var File_fleetspeak_src_server_proto_fleetspeak_server_broadcasts_proto protoreflect.FileDescriptor + var File_fleetspeak_src_server_proto_fleetspeak_server_resource_proto protoreflect.FileDescriptor + var File_fleetspeak_src_server_proto_fleetspeak_server_server_proto protoreflect.FileDescriptor + var File_fleetspeak_src_server_proto_fleetspeak_server_services_proto protoreflect.FileDescriptor + func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer) + type AdminClient interface + BlacklistClient func(ctx context.Context, in *BlacklistClientRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error) + CreateBroadcast func(ctx context.Context, in *CreateBroadcastRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error) + DeletePendingMessages func(ctx context.Context, in *DeletePendingMessagesRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error) + FetchClientResourceUsageRecords func(ctx context.Context, in *FetchClientResourceUsageRecordsRequest, ...) (*FetchClientResourceUsageRecordsResponse, error) + GetMessageStatus func(ctx context.Context, in *GetMessageStatusRequest, opts ...grpc.CallOption) (*GetMessageStatusResponse, error) + GetPendingMessageCount func(ctx context.Context, in *GetPendingMessageCountRequest, ...) (*GetPendingMessageCountResponse, error) + GetPendingMessages func(ctx context.Context, in *GetPendingMessagesRequest, opts ...grpc.CallOption) (*GetPendingMessagesResponse, error) + InsertMessage func(ctx context.Context, in *fleetspeak.Message, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error) + KeepAlive func(ctx context.Context, in *fleetspeak.EmptyMessage, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error) + ListActiveBroadcasts func(ctx context.Context, in *ListActiveBroadcastsRequest, opts ...grpc.CallOption) (*ListActiveBroadcastsResponse, error) + ListClientContacts func(ctx context.Context, in *ListClientContactsRequest, opts ...grpc.CallOption) (*ListClientContactsResponse, error) + ListClients func(ctx context.Context, in *ListClientsRequest, opts ...grpc.CallOption) (*ListClientsResponse, error) + StoreFile func(ctx context.Context, in *StoreFileRequest, opts ...grpc.CallOption) (*fleetspeak.EmptyMessage, error) + StreamClientContacts func(ctx context.Context, in *StreamClientContactsRequest, opts ...grpc.CallOption) (Admin_StreamClientContactsClient, error) + StreamClientIds func(ctx context.Context, in *StreamClientIdsRequest, opts ...grpc.CallOption) (Admin_StreamClientIdsClient, error) + func NewAdminClient(cc grpc.ClientConnInterface) AdminClient + type AdminServer interface + BlacklistClient func(context.Context, *BlacklistClientRequest) (*fleetspeak.EmptyMessage, error) + CreateBroadcast func(context.Context, *CreateBroadcastRequest) (*fleetspeak.EmptyMessage, error) + DeletePendingMessages func(context.Context, *DeletePendingMessagesRequest) (*fleetspeak.EmptyMessage, error) + FetchClientResourceUsageRecords func(context.Context, *FetchClientResourceUsageRecordsRequest) (*FetchClientResourceUsageRecordsResponse, error) + GetMessageStatus func(context.Context, *GetMessageStatusRequest) (*GetMessageStatusResponse, error) + GetPendingMessageCount func(context.Context, *GetPendingMessageCountRequest) (*GetPendingMessageCountResponse, error) + GetPendingMessages func(context.Context, *GetPendingMessagesRequest) (*GetPendingMessagesResponse, error) + InsertMessage func(context.Context, *fleetspeak.Message) (*fleetspeak.EmptyMessage, error) + KeepAlive func(context.Context, *fleetspeak.EmptyMessage) (*fleetspeak.EmptyMessage, error) + ListActiveBroadcasts func(context.Context, *ListActiveBroadcastsRequest) (*ListActiveBroadcastsResponse, error) + ListClientContacts func(context.Context, *ListClientContactsRequest) (*ListClientContactsResponse, error) + ListClients func(context.Context, *ListClientsRequest) (*ListClientsResponse, error) + StoreFile func(context.Context, *StoreFileRequest) (*fleetspeak.EmptyMessage, error) + StreamClientContacts func(*StreamClientContactsRequest, Admin_StreamClientContactsServer) error + StreamClientIds func(*StreamClientIdsRequest, Admin_StreamClientIdsServer) error + type Admin_StreamClientContactsClient interface + Recv func() (*StreamClientContactsResponse, error) + type Admin_StreamClientContactsServer interface + Send func(*StreamClientContactsResponse) error + type Admin_StreamClientIdsClient interface + Recv func() (*StreamClientIdsResponse, error) + type Admin_StreamClientIdsServer interface + Send func(*StreamClientIdsResponse) error + type BlacklistClientRequest struct + ClientId []byte + func (*BlacklistClientRequest) Descriptor() ([]byte, []int) + func (*BlacklistClientRequest) ProtoMessage() + func (x *BlacklistClientRequest) GetClientId() []byte + func (x *BlacklistClientRequest) ProtoReflect() protoreflect.Message + func (x *BlacklistClientRequest) Reset() + func (x *BlacklistClientRequest) String() string + type Broadcast struct + BroadcastId []byte + Data *anypb.Any + ExpirationTime *timestamppb.Timestamp + MessageType string + RequiredLabels []*fleetspeak.Label + Source *fleetspeak.Address + func (*Broadcast) Descriptor() ([]byte, []int) + func (*Broadcast) ProtoMessage() + func (x *Broadcast) GetBroadcastId() []byte + func (x *Broadcast) GetData() *anypb.Any + func (x *Broadcast) GetExpirationTime() *timestamppb.Timestamp + func (x *Broadcast) GetMessageType() string + func (x *Broadcast) GetRequiredLabels() []*fleetspeak.Label + func (x *Broadcast) GetSource() *fleetspeak.Address + func (x *Broadcast) ProtoReflect() protoreflect.Message + func (x *Broadcast) Reset() + func (x *Broadcast) String() string + type Client struct + Blacklisted bool + ClientId []byte + Labels []*fleetspeak.Label + LastClock *timestamppb.Timestamp + LastContactAddress string + LastContactStreamingTo string + LastContactTime *timestamppb.Timestamp + func (*Client) Descriptor() ([]byte, []int) + func (*Client) ProtoMessage() + func (x *Client) GetBlacklisted() bool + func (x *Client) GetClientId() []byte + func (x *Client) GetLabels() []*fleetspeak.Label + func (x *Client) GetLastClock() *timestamppb.Timestamp + func (x *Client) GetLastContactAddress() string + func (x *Client) GetLastContactStreamingTo() string + func (x *Client) GetLastContactTime() *timestamppb.Timestamp + func (x *Client) ProtoReflect() protoreflect.Message + func (x *Client) Reset() + func (x *Client) String() string + type ClientContact struct + ObservedAddress string + ReceivedNonce uint64 + SentNonce uint64 + Timestamp *timestamppb.Timestamp + func (*ClientContact) Descriptor() ([]byte, []int) + func (*ClientContact) ProtoMessage() + func (x *ClientContact) GetObservedAddress() string + func (x *ClientContact) GetReceivedNonce() uint64 + func (x *ClientContact) GetSentNonce() uint64 + func (x *ClientContact) GetTimestamp() *timestamppb.Timestamp + func (x *ClientContact) ProtoReflect() protoreflect.Message + func (x *ClientContact) Reset() + func (x *ClientContact) String() string + type ClientResourceUsageRecord struct + ClientTimestamp *timestamppb.Timestamp + MaxNumFds int32 + MaxResidentMemoryMib int32 + MaxSystemCpuRate float32 + MaxUserCpuRate float32 + MeanNumFds int32 + MeanResidentMemoryMib int32 + MeanSystemCpuRate float32 + MeanUserCpuRate float32 + Pid int64 + ProcessStartTime *timestamppb.Timestamp + ProcessTerminated bool + Scope string + ServerTimestamp *timestamppb.Timestamp + func (*ClientResourceUsageRecord) Descriptor() ([]byte, []int) + func (*ClientResourceUsageRecord) ProtoMessage() + func (x *ClientResourceUsageRecord) GetClientTimestamp() *timestamppb.Timestamp + func (x *ClientResourceUsageRecord) GetMaxNumFds() int32 + func (x *ClientResourceUsageRecord) GetMaxResidentMemoryMib() int32 + func (x *ClientResourceUsageRecord) GetMaxSystemCpuRate() float32 + func (x *ClientResourceUsageRecord) GetMaxUserCpuRate() float32 + func (x *ClientResourceUsageRecord) GetMeanNumFds() int32 + func (x *ClientResourceUsageRecord) GetMeanResidentMemoryMib() int32 + func (x *ClientResourceUsageRecord) GetMeanSystemCpuRate() float32 + func (x *ClientResourceUsageRecord) GetMeanUserCpuRate() float32 + func (x *ClientResourceUsageRecord) GetPid() int64 + func (x *ClientResourceUsageRecord) GetProcessStartTime() *timestamppb.Timestamp + func (x *ClientResourceUsageRecord) GetProcessTerminated() bool + func (x *ClientResourceUsageRecord) GetScope() string + func (x *ClientResourceUsageRecord) GetServerTimestamp() *timestamppb.Timestamp + func (x *ClientResourceUsageRecord) ProtoReflect() protoreflect.Message + func (x *ClientResourceUsageRecord) Reset() + func (x *ClientResourceUsageRecord) String() string + type CreateBroadcastRequest struct + Broadcast *Broadcast + Limit uint64 + func (*CreateBroadcastRequest) Descriptor() ([]byte, []int) + func (*CreateBroadcastRequest) ProtoMessage() + func (x *CreateBroadcastRequest) GetBroadcast() *Broadcast + func (x *CreateBroadcastRequest) GetLimit() uint64 + func (x *CreateBroadcastRequest) ProtoReflect() protoreflect.Message + func (x *CreateBroadcastRequest) Reset() + func (x *CreateBroadcastRequest) String() string + type DeletePendingMessagesRequest struct + ClientIds [][]byte + func (*DeletePendingMessagesRequest) Descriptor() ([]byte, []int) + func (*DeletePendingMessagesRequest) ProtoMessage() + func (x *DeletePendingMessagesRequest) GetClientIds() [][]byte + func (x *DeletePendingMessagesRequest) ProtoReflect() protoreflect.Message + func (x *DeletePendingMessagesRequest) Reset() + func (x *DeletePendingMessagesRequest) String() string + type FetchClientResourceUsageRecordsRequest struct + ClientId []byte + EndTimestamp *timestamppb.Timestamp + StartTimestamp *timestamppb.Timestamp + func (*FetchClientResourceUsageRecordsRequest) Descriptor() ([]byte, []int) + func (*FetchClientResourceUsageRecordsRequest) ProtoMessage() + func (x *FetchClientResourceUsageRecordsRequest) GetClientId() []byte + func (x *FetchClientResourceUsageRecordsRequest) GetEndTimestamp() *timestamppb.Timestamp + func (x *FetchClientResourceUsageRecordsRequest) GetStartTimestamp() *timestamppb.Timestamp + func (x *FetchClientResourceUsageRecordsRequest) ProtoReflect() protoreflect.Message + func (x *FetchClientResourceUsageRecordsRequest) Reset() + func (x *FetchClientResourceUsageRecordsRequest) String() string + type FetchClientResourceUsageRecordsResponse struct + Records []*ClientResourceUsageRecord + func (*FetchClientResourceUsageRecordsResponse) Descriptor() ([]byte, []int) + func (*FetchClientResourceUsageRecordsResponse) ProtoMessage() + func (x *FetchClientResourceUsageRecordsResponse) GetRecords() []*ClientResourceUsageRecord + func (x *FetchClientResourceUsageRecordsResponse) ProtoReflect() protoreflect.Message + func (x *FetchClientResourceUsageRecordsResponse) Reset() + func (x *FetchClientResourceUsageRecordsResponse) String() string + type GetMessageStatusRequest struct + MessageId []byte + func (*GetMessageStatusRequest) Descriptor() ([]byte, []int) + func (*GetMessageStatusRequest) ProtoMessage() + func (x *GetMessageStatusRequest) GetMessageId() []byte + func (x *GetMessageStatusRequest) ProtoReflect() protoreflect.Message + func (x *GetMessageStatusRequest) Reset() + func (x *GetMessageStatusRequest) String() string + type GetMessageStatusResponse struct + CreationTime *timestamppb.Timestamp + Result *fleetspeak.MessageResult + func (*GetMessageStatusResponse) Descriptor() ([]byte, []int) + func (*GetMessageStatusResponse) ProtoMessage() + func (x *GetMessageStatusResponse) GetCreationTime() *timestamppb.Timestamp + func (x *GetMessageStatusResponse) GetResult() *fleetspeak.MessageResult + func (x *GetMessageStatusResponse) ProtoReflect() protoreflect.Message + func (x *GetMessageStatusResponse) Reset() + func (x *GetMessageStatusResponse) String() string + type GetPendingMessageCountRequest struct + ClientIds [][]byte + func (*GetPendingMessageCountRequest) Descriptor() ([]byte, []int) + func (*GetPendingMessageCountRequest) ProtoMessage() + func (x *GetPendingMessageCountRequest) GetClientIds() [][]byte + func (x *GetPendingMessageCountRequest) ProtoReflect() protoreflect.Message + func (x *GetPendingMessageCountRequest) Reset() + func (x *GetPendingMessageCountRequest) String() string + type GetPendingMessageCountResponse struct + Count uint64 + func (*GetPendingMessageCountResponse) Descriptor() ([]byte, []int) + func (*GetPendingMessageCountResponse) ProtoMessage() + func (x *GetPendingMessageCountResponse) GetCount() uint64 + func (x *GetPendingMessageCountResponse) ProtoReflect() protoreflect.Message + func (x *GetPendingMessageCountResponse) Reset() + func (x *GetPendingMessageCountResponse) String() string + type GetPendingMessagesRequest struct + ClientIds [][]byte + Limit uint64 + Offset uint64 + WantData bool + func (*GetPendingMessagesRequest) Descriptor() ([]byte, []int) + func (*GetPendingMessagesRequest) ProtoMessage() + func (x *GetPendingMessagesRequest) GetClientIds() [][]byte + func (x *GetPendingMessagesRequest) GetLimit() uint64 + func (x *GetPendingMessagesRequest) GetOffset() uint64 + func (x *GetPendingMessagesRequest) GetWantData() bool + func (x *GetPendingMessagesRequest) ProtoReflect() protoreflect.Message + func (x *GetPendingMessagesRequest) Reset() + func (x *GetPendingMessagesRequest) String() string + type GetPendingMessagesResponse struct + Messages []*fleetspeak.Message + func (*GetPendingMessagesResponse) Descriptor() ([]byte, []int) + func (*GetPendingMessagesResponse) ProtoMessage() + func (x *GetPendingMessagesResponse) GetMessages() []*fleetspeak.Message + func (x *GetPendingMessagesResponse) ProtoReflect() protoreflect.Message + func (x *GetPendingMessagesResponse) Reset() + func (x *GetPendingMessagesResponse) String() string + type ListActiveBroadcastsRequest struct + ServiceName string + func (*ListActiveBroadcastsRequest) Descriptor() ([]byte, []int) + func (*ListActiveBroadcastsRequest) ProtoMessage() + func (x *ListActiveBroadcastsRequest) GetServiceName() string + func (x *ListActiveBroadcastsRequest) ProtoReflect() protoreflect.Message + func (x *ListActiveBroadcastsRequest) Reset() + func (x *ListActiveBroadcastsRequest) String() string + type ListActiveBroadcastsResponse struct + Broadcasts []*Broadcast + func (*ListActiveBroadcastsResponse) Descriptor() ([]byte, []int) + func (*ListActiveBroadcastsResponse) ProtoMessage() + func (x *ListActiveBroadcastsResponse) GetBroadcasts() []*Broadcast + func (x *ListActiveBroadcastsResponse) ProtoReflect() protoreflect.Message + func (x *ListActiveBroadcastsResponse) Reset() + func (x *ListActiveBroadcastsResponse) String() string + type ListClientContactsRequest struct + ClientId []byte + func (*ListClientContactsRequest) Descriptor() ([]byte, []int) + func (*ListClientContactsRequest) ProtoMessage() + func (x *ListClientContactsRequest) GetClientId() []byte + func (x *ListClientContactsRequest) ProtoReflect() protoreflect.Message + func (x *ListClientContactsRequest) Reset() + func (x *ListClientContactsRequest) String() string + type ListClientContactsResponse struct + Contacts []*ClientContact + func (*ListClientContactsResponse) Descriptor() ([]byte, []int) + func (*ListClientContactsResponse) ProtoMessage() + func (x *ListClientContactsResponse) GetContacts() []*ClientContact + func (x *ListClientContactsResponse) ProtoReflect() protoreflect.Message + func (x *ListClientContactsResponse) Reset() + func (x *ListClientContactsResponse) String() string + type ListClientsRequest struct + ClientIds [][]byte + func (*ListClientsRequest) Descriptor() ([]byte, []int) + func (*ListClientsRequest) ProtoMessage() + func (x *ListClientsRequest) GetClientIds() [][]byte + func (x *ListClientsRequest) ProtoReflect() protoreflect.Message + func (x *ListClientsRequest) Reset() + func (x *ListClientsRequest) String() string + type ListClientsResponse struct + Clients []*Client + func (*ListClientsResponse) Descriptor() ([]byte, []int) + func (*ListClientsResponse) ProtoMessage() + func (x *ListClientsResponse) GetClients() []*Client + func (x *ListClientsResponse) ProtoReflect() protoreflect.Message + func (x *ListClientsResponse) Reset() + func (x *ListClientsResponse) String() string + type ServerConfig struct + BroadcastPollTime *durationpb.Duration + Services []*ServiceConfig + func (*ServerConfig) Descriptor() ([]byte, []int) + func (*ServerConfig) ProtoMessage() + func (x *ServerConfig) GetBroadcastPollTime() *durationpb.Duration + func (x *ServerConfig) GetServices() []*ServiceConfig + func (x *ServerConfig) ProtoReflect() protoreflect.Message + func (x *ServerConfig) Reset() + func (x *ServerConfig) String() string + type ServiceConfig struct + Config *anypb.Any + Factory string + MaxParallelism uint32 + Name string + func (*ServiceConfig) Descriptor() ([]byte, []int) + func (*ServiceConfig) ProtoMessage() + func (x *ServiceConfig) GetConfig() *anypb.Any + func (x *ServiceConfig) GetFactory() string + func (x *ServiceConfig) GetMaxParallelism() uint32 + func (x *ServiceConfig) GetName() string + func (x *ServiceConfig) ProtoReflect() protoreflect.Message + func (x *ServiceConfig) Reset() + func (x *ServiceConfig) String() string + type StoreFileRequest struct + Data []byte + FileName string + ServiceName string + func (*StoreFileRequest) Descriptor() ([]byte, []int) + func (*StoreFileRequest) ProtoMessage() + func (x *StoreFileRequest) GetData() []byte + func (x *StoreFileRequest) GetFileName() string + func (x *StoreFileRequest) GetServiceName() string + func (x *StoreFileRequest) ProtoReflect() protoreflect.Message + func (x *StoreFileRequest) Reset() + func (x *StoreFileRequest) String() string + type StreamClientContactsRequest struct + ClientId []byte + func (*StreamClientContactsRequest) Descriptor() ([]byte, []int) + func (*StreamClientContactsRequest) ProtoMessage() + func (x *StreamClientContactsRequest) GetClientId() []byte + func (x *StreamClientContactsRequest) ProtoReflect() protoreflect.Message + func (x *StreamClientContactsRequest) Reset() + func (x *StreamClientContactsRequest) String() string + type StreamClientContactsResponse struct + Contact *ClientContact + func (*StreamClientContactsResponse) Descriptor() ([]byte, []int) + func (*StreamClientContactsResponse) ProtoMessage() + func (x *StreamClientContactsResponse) GetContact() *ClientContact + func (x *StreamClientContactsResponse) ProtoReflect() protoreflect.Message + func (x *StreamClientContactsResponse) Reset() + func (x *StreamClientContactsResponse) String() string + type StreamClientIdsRequest struct + IncludeBlacklisted bool + LastContactAfter *timestamppb.Timestamp + func (*StreamClientIdsRequest) Descriptor() ([]byte, []int) + func (*StreamClientIdsRequest) ProtoMessage() + func (x *StreamClientIdsRequest) GetIncludeBlacklisted() bool + func (x *StreamClientIdsRequest) GetLastContactAfter() *timestamppb.Timestamp + func (x *StreamClientIdsRequest) ProtoReflect() protoreflect.Message + func (x *StreamClientIdsRequest) Reset() + func (x *StreamClientIdsRequest) String() string + type StreamClientIdsResponse struct + ClientId []byte + func (*StreamClientIdsResponse) Descriptor() ([]byte, []int) + func (*StreamClientIdsResponse) ProtoMessage() + func (x *StreamClientIdsResponse) GetClientId() []byte + func (x *StreamClientIdsResponse) ProtoReflect() protoreflect.Message + func (x *StreamClientIdsResponse) Reset() + func (x *StreamClientIdsResponse) String() string + type UnimplementedAdminServer struct + func (UnimplementedAdminServer) BlacklistClient(context.Context, *BlacklistClientRequest) (*fleetspeak.EmptyMessage, error) + func (UnimplementedAdminServer) CreateBroadcast(context.Context, *CreateBroadcastRequest) (*fleetspeak.EmptyMessage, error) + func (UnimplementedAdminServer) DeletePendingMessages(context.Context, *DeletePendingMessagesRequest) (*fleetspeak.EmptyMessage, error) + func (UnimplementedAdminServer) FetchClientResourceUsageRecords(context.Context, *FetchClientResourceUsageRecordsRequest) (*FetchClientResourceUsageRecordsResponse, error) + func (UnimplementedAdminServer) GetMessageStatus(context.Context, *GetMessageStatusRequest) (*GetMessageStatusResponse, error) + func (UnimplementedAdminServer) GetPendingMessageCount(context.Context, *GetPendingMessageCountRequest) (*GetPendingMessageCountResponse, error) + func (UnimplementedAdminServer) GetPendingMessages(context.Context, *GetPendingMessagesRequest) (*GetPendingMessagesResponse, error) + func (UnimplementedAdminServer) InsertMessage(context.Context, *fleetspeak.Message) (*fleetspeak.EmptyMessage, error) + func (UnimplementedAdminServer) KeepAlive(context.Context, *fleetspeak.EmptyMessage) (*fleetspeak.EmptyMessage, error) + func (UnimplementedAdminServer) ListActiveBroadcasts(context.Context, *ListActiveBroadcastsRequest) (*ListActiveBroadcastsResponse, error) + func (UnimplementedAdminServer) ListClientContacts(context.Context, *ListClientContactsRequest) (*ListClientContactsResponse, error) + func (UnimplementedAdminServer) ListClients(context.Context, *ListClientsRequest) (*ListClientsResponse, error) + func (UnimplementedAdminServer) StoreFile(context.Context, *StoreFileRequest) (*fleetspeak.EmptyMessage, error) + func (UnimplementedAdminServer) StreamClientContacts(*StreamClientContactsRequest, Admin_StreamClientContactsServer) error + func (UnimplementedAdminServer) StreamClientIds(*StreamClientIdsRequest, Admin_StreamClientIdsServer) error + type UnsafeAdminServer interface