Documentation
¶
Index ¶
- Constants
- Variables
- func DeleteAgent(cnf *config.Config) error
- func RegisterCollector(cnf *config.Config, UTMKey string) error
- func RegisterCollectorServiceServer(s grpc.ServiceRegistrar, srv CollectorServiceServer)
- func RegisterPanelCollectorServiceServer(s grpc.ServiceRegistrar, srv PanelCollectorServiceServer)
- func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)
- func StartPing(cnf *config.Config, ctx context.Context)
- func UninstallAll() error
- type AuthResponse
- func (*AuthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AuthResponse) GetId() uint32
- func (x *AuthResponse) GetKey() string
- func (*AuthResponse) ProtoMessage()
- func (x *AuthResponse) ProtoReflect() protoreflect.Message
- func (x *AuthResponse) Reset()
- func (x *AuthResponse) String() string
- type Collector
- func (*Collector) Descriptor() ([]byte, []int)deprecated
- func (x *Collector) GetCollectorKey() string
- func (x *Collector) GetHostname() string
- func (x *Collector) GetId() int32
- func (x *Collector) GetIp() string
- func (x *Collector) GetLastSeen() string
- func (x *Collector) GetModule() CollectorModule
- func (x *Collector) GetStatus() Status
- func (x *Collector) GetVersion() string
- func (*Collector) ProtoMessage()
- func (x *Collector) ProtoReflect() protoreflect.Message
- func (x *Collector) Reset()
- func (x *Collector) String() string
- type CollectorConfig
- func (*CollectorConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorConfig) GetCollectorId() string
- func (x *CollectorConfig) GetGroups() []*CollectorConfigGroup
- func (x *CollectorConfig) GetRequestId() string
- func (*CollectorConfig) ProtoMessage()
- func (x *CollectorConfig) ProtoReflect() protoreflect.Message
- func (x *CollectorConfig) Reset()
- func (x *CollectorConfig) String() string
- type CollectorConfigGroup
- func (*CollectorConfigGroup) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorConfigGroup) GetCollectorId() int32
- func (x *CollectorConfigGroup) GetConfigurations() []*CollectorGroupConfigurations
- func (x *CollectorConfigGroup) GetGroupDescription() string
- func (x *CollectorConfigGroup) GetGroupName() string
- func (x *CollectorConfigGroup) GetId() int32
- func (*CollectorConfigGroup) ProtoMessage()
- func (x *CollectorConfigGroup) ProtoReflect() protoreflect.Message
- func (x *CollectorConfigGroup) Reset()
- func (x *CollectorConfigGroup) String() string
- type CollectorGroupConfigurations
- func (*CollectorGroupConfigurations) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorGroupConfigurations) GetConfDataType() string
- func (x *CollectorGroupConfigurations) GetConfDescription() string
- func (x *CollectorGroupConfigurations) GetConfKey() string
- func (x *CollectorGroupConfigurations) GetConfName() string
- func (x *CollectorGroupConfigurations) GetConfRequired() bool
- func (x *CollectorGroupConfigurations) GetConfValue() string
- func (x *CollectorGroupConfigurations) GetGroupId() int32
- func (x *CollectorGroupConfigurations) GetId() int32
- func (*CollectorGroupConfigurations) ProtoMessage()
- func (x *CollectorGroupConfigurations) ProtoReflect() protoreflect.Message
- func (x *CollectorGroupConfigurations) Reset()
- func (x *CollectorGroupConfigurations) String() string
- type CollectorMessages
- func (*CollectorMessages) Descriptor() ([]byte, []int)deprecated
- func (x *CollectorMessages) GetConfig() *CollectorConfig
- func (x *CollectorMessages) GetResult() *ConfigKnowledge
- func (x *CollectorMessages) GetStreamMessage() isCollectorMessages_StreamMessage
- func (*CollectorMessages) ProtoMessage()
- func (x *CollectorMessages) ProtoReflect() protoreflect.Message
- func (x *CollectorMessages) Reset()
- func (x *CollectorMessages) String() string
- type CollectorMessages_Config
- type CollectorMessages_Result
- type CollectorModule
- func (CollectorModule) Descriptor() protoreflect.EnumDescriptor
- func (x CollectorModule) Enum() *CollectorModule
- func (CollectorModule) EnumDescriptor() ([]byte, []int)deprecated
- func (x CollectorModule) Number() protoreflect.EnumNumber
- func (x CollectorModule) String() string
- func (CollectorModule) Type() protoreflect.EnumType
- type CollectorServiceClient
- type CollectorServiceServer
- type CollectorService_CollectorStreamClient
- type CollectorService_CollectorStreamServer
- type ConfigKnowledge
- func (*ConfigKnowledge) Descriptor() ([]byte, []int)deprecated
- func (x *ConfigKnowledge) GetAccepted() string
- func (x *ConfigKnowledge) GetRequestId() string
- func (*ConfigKnowledge) ProtoMessage()
- func (x *ConfigKnowledge) ProtoReflect() protoreflect.Message
- func (x *ConfigKnowledge) Reset()
- func (x *ConfigKnowledge) String() string
- type ConfigRequest
- type ConnectorType
- func (ConnectorType) Descriptor() protoreflect.EnumDescriptor
- func (x ConnectorType) Enum() *ConnectorType
- func (ConnectorType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConnectorType) Number() protoreflect.EnumNumber
- func (x ConnectorType) String() string
- func (ConnectorType) Type() protoreflect.EnumType
- type DeleteRequest
- type ListCollectorResponse
- func (*ListCollectorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListCollectorResponse) GetRows() []*Collector
- func (x *ListCollectorResponse) GetTotal() int32
- func (*ListCollectorResponse) ProtoMessage()
- func (x *ListCollectorResponse) ProtoReflect() protoreflect.Message
- func (x *ListCollectorResponse) Reset()
- func (x *ListCollectorResponse) String() string
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetPageNumber() int32
- func (x *ListRequest) GetPageSize() int32
- func (x *ListRequest) GetSearchQuery() string
- func (x *ListRequest) GetSortBy() string
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type PanelCollectorServiceClient
- type PanelCollectorServiceServer
- type PingRequest
- type PingResponse
- type PingServiceClient
- type PingServiceServer
- type PingService_PingClient
- type PingService_PingServer
- type RegisterRequest
- func (*RegisterRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterRequest) GetCollector() CollectorModule
- func (x *RegisterRequest) GetHostname() string
- func (x *RegisterRequest) GetIp() string
- func (x *RegisterRequest) GetVersion() string
- func (*RegisterRequest) ProtoMessage()
- func (x *RegisterRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterRequest) Reset()
- func (x *RegisterRequest) String() string
- type Status
- type UnimplementedCollectorServiceServer
- func (UnimplementedCollectorServiceServer) CollectorStream(grpc.BidiStreamingServer[CollectorMessages, CollectorMessages]) error
- func (UnimplementedCollectorServiceServer) DeleteCollector(context.Context, *DeleteRequest) (*AuthResponse, error)
- func (UnimplementedCollectorServiceServer) GetCollectorConfig(context.Context, *ConfigRequest) (*CollectorConfig, error)
- func (UnimplementedCollectorServiceServer) ListCollector(context.Context, *ListRequest) (*ListCollectorResponse, error)
- func (UnimplementedCollectorServiceServer) RegisterCollector(context.Context, *RegisterRequest) (*AuthResponse, error)
- type UnimplementedPanelCollectorServiceServer
- type UnimplementedPingServiceServer
- type UnsafeCollectorServiceServer
- type UnsafePanelCollectorServiceServer
- type UnsafePingServiceServer
Constants ¶
const ( CollectorService_RegisterCollector_FullMethodName = "/agent.CollectorService/RegisterCollector" CollectorService_DeleteCollector_FullMethodName = "/agent.CollectorService/DeleteCollector" CollectorService_ListCollector_FullMethodName = "/agent.CollectorService/ListCollector" CollectorService_CollectorStream_FullMethodName = "/agent.CollectorService/CollectorStream" CollectorService_GetCollectorConfig_FullMethodName = "/agent.CollectorService/GetCollectorConfig" )
const (
PanelCollectorService_RegisterCollectorConfig_FullMethodName = "/agent.PanelCollectorService/RegisterCollectorConfig"
)
const (
PingService_Ping_FullMethodName = "/agent.PingService/Ping"
)
Variables ¶
var ( CollectorModule_name = map[int32]string{ 0: "AS_400", 1: "UTMSTACK", } CollectorModule_value = map[string]int32{ "AS_400": 0, "UTMSTACK": 1, } )
Enum value maps for CollectorModule.
var ( Status_name = map[int32]string{ 0: "ONLINE", 1: "OFFLINE", 2: "UNKNOWN", } Status_value = map[string]int32{ "ONLINE": 0, "OFFLINE": 1, "UNKNOWN": 2, } )
Enum value maps for Status.
var ( ConnectorType_name = map[int32]string{ 0: "AGENT", 1: "COLLECTOR", } ConnectorType_value = map[string]int32{ "AGENT": 0, "COLLECTOR": 1, } )
Enum value maps for ConnectorType.
var CollectorService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.CollectorService", HandlerType: (*CollectorServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterCollector", Handler: _CollectorService_RegisterCollector_Handler, }, { MethodName: "DeleteCollector", Handler: _CollectorService_DeleteCollector_Handler, }, { MethodName: "ListCollector", Handler: _CollectorService_ListCollector_Handler, }, { MethodName: "GetCollectorConfig", Handler: _CollectorService_GetCollectorConfig_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "CollectorStream", Handler: _CollectorService_CollectorStream_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "collector.proto", }
CollectorService_ServiceDesc is the grpc.ServiceDesc for CollectorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_collector_proto protoreflect.FileDescriptor
var File_common_proto protoreflect.FileDescriptor
var File_ping_proto protoreflect.FileDescriptor
var PanelCollectorService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.PanelCollectorService", HandlerType: (*PanelCollectorServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterCollectorConfig", Handler: _PanelCollectorService_RegisterCollectorConfig_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "collector.proto", }
PanelCollectorService_ServiceDesc is the grpc.ServiceDesc for PanelCollectorService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var PingService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "agent.PingService", HandlerType: (*PingServiceServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "Ping", Handler: _PingService_Ping_Handler, ClientStreams: true, }, }, Metadata: "ping.proto", }
PingService_ServiceDesc is the grpc.ServiceDesc for PingService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func DeleteAgent ¶
func RegisterCollectorServiceServer ¶
func RegisterCollectorServiceServer(s grpc.ServiceRegistrar, srv CollectorServiceServer)
func RegisterPanelCollectorServiceServer ¶
func RegisterPanelCollectorServiceServer(s grpc.ServiceRegistrar, srv PanelCollectorServiceServer)
func RegisterPingServiceServer ¶
func RegisterPingServiceServer(s grpc.ServiceRegistrar, srv PingServiceServer)
func UninstallAll ¶
func UninstallAll() error
Types ¶
type AuthResponse ¶
type AuthResponse struct {
Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
func (*AuthResponse) Descriptor
deprecated
func (*AuthResponse) Descriptor() ([]byte, []int)
Deprecated: Use AuthResponse.ProtoReflect.Descriptor instead.
func (*AuthResponse) GetId ¶
func (x *AuthResponse) GetId() uint32
func (*AuthResponse) GetKey ¶
func (x *AuthResponse) GetKey() string
func (*AuthResponse) ProtoMessage ¶
func (*AuthResponse) ProtoMessage()
func (*AuthResponse) ProtoReflect ¶
func (x *AuthResponse) ProtoReflect() protoreflect.Message
func (*AuthResponse) Reset ¶
func (x *AuthResponse) Reset()
func (*AuthResponse) String ¶
func (x *AuthResponse) String() string
type Collector ¶
type Collector struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Status Status `protobuf:"varint,2,opt,name=status,proto3,enum=agent.Status" json:"status,omitempty"`
CollectorKey string `protobuf:"bytes,3,opt,name=collector_key,json=collectorKey,proto3" json:"collector_key,omitempty"`
Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
Hostname string `protobuf:"bytes,5,opt,name=hostname,proto3" json:"hostname,omitempty"`
Version string `protobuf:"bytes,6,opt,name=version,proto3" json:"version,omitempty"`
Module CollectorModule `protobuf:"varint,7,opt,name=module,proto3,enum=agent.CollectorModule" json:"module,omitempty"`
LastSeen string `protobuf:"bytes,8,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
// contains filtered or unexported fields
}
func (*Collector) Descriptor
deprecated
func (*Collector) GetCollectorKey ¶
func (*Collector) GetHostname ¶
func (*Collector) GetLastSeen ¶
func (*Collector) GetModule ¶
func (x *Collector) GetModule() CollectorModule
func (*Collector) GetVersion ¶
func (*Collector) ProtoMessage ¶
func (*Collector) ProtoMessage()
func (*Collector) ProtoReflect ¶
func (x *Collector) ProtoReflect() protoreflect.Message
type CollectorConfig ¶
type CollectorConfig struct {
CollectorId string `protobuf:"bytes,1,opt,name=collector_id,json=collectorId,proto3" json:"collector_id,omitempty"`
Groups []*CollectorConfigGroup `protobuf:"bytes,2,rep,name=groups,proto3" json:"groups,omitempty"`
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*CollectorConfig) Descriptor
deprecated
func (*CollectorConfig) Descriptor() ([]byte, []int)
Deprecated: Use CollectorConfig.ProtoReflect.Descriptor instead.
func (*CollectorConfig) GetCollectorId ¶
func (x *CollectorConfig) GetCollectorId() string
func (*CollectorConfig) GetGroups ¶
func (x *CollectorConfig) GetGroups() []*CollectorConfigGroup
func (*CollectorConfig) GetRequestId ¶
func (x *CollectorConfig) GetRequestId() string
func (*CollectorConfig) ProtoMessage ¶
func (*CollectorConfig) ProtoMessage()
func (*CollectorConfig) ProtoReflect ¶
func (x *CollectorConfig) ProtoReflect() protoreflect.Message
func (*CollectorConfig) Reset ¶
func (x *CollectorConfig) Reset()
func (*CollectorConfig) String ¶
func (x *CollectorConfig) String() string
type CollectorConfigGroup ¶
type CollectorConfigGroup struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
GroupName string `protobuf:"bytes,2,opt,name=group_name,json=groupName,proto3" json:"group_name,omitempty"`
GroupDescription string `protobuf:"bytes,3,opt,name=group_description,json=groupDescription,proto3" json:"group_description,omitempty"`
Configurations []*CollectorGroupConfigurations `protobuf:"bytes,4,rep,name=configurations,proto3" json:"configurations,omitempty"`
CollectorId int32 `protobuf:"varint,5,opt,name=collector_id,json=collectorId,proto3" json:"collector_id,omitempty"`
// contains filtered or unexported fields
}
func (*CollectorConfigGroup) Descriptor
deprecated
func (*CollectorConfigGroup) Descriptor() ([]byte, []int)
Deprecated: Use CollectorConfigGroup.ProtoReflect.Descriptor instead.
func (*CollectorConfigGroup) GetCollectorId ¶
func (x *CollectorConfigGroup) GetCollectorId() int32
func (*CollectorConfigGroup) GetConfigurations ¶
func (x *CollectorConfigGroup) GetConfigurations() []*CollectorGroupConfigurations
func (*CollectorConfigGroup) GetGroupDescription ¶
func (x *CollectorConfigGroup) GetGroupDescription() string
func (*CollectorConfigGroup) GetGroupName ¶
func (x *CollectorConfigGroup) GetGroupName() string
func (*CollectorConfigGroup) GetId ¶
func (x *CollectorConfigGroup) GetId() int32
func (*CollectorConfigGroup) ProtoMessage ¶
func (*CollectorConfigGroup) ProtoMessage()
func (*CollectorConfigGroup) ProtoReflect ¶
func (x *CollectorConfigGroup) ProtoReflect() protoreflect.Message
func (*CollectorConfigGroup) Reset ¶
func (x *CollectorConfigGroup) Reset()
func (*CollectorConfigGroup) String ¶
func (x *CollectorConfigGroup) String() string
type CollectorGroupConfigurations ¶
type CollectorGroupConfigurations struct {
Id int32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
GroupId int32 `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
ConfKey string `protobuf:"bytes,3,opt,name=conf_key,json=confKey,proto3" json:"conf_key,omitempty"`
ConfValue string `protobuf:"bytes,4,opt,name=conf_value,json=confValue,proto3" json:"conf_value,omitempty"`
ConfName string `protobuf:"bytes,5,opt,name=conf_name,json=confName,proto3" json:"conf_name,omitempty"`
ConfDescription string `protobuf:"bytes,6,opt,name=conf_description,json=confDescription,proto3" json:"conf_description,omitempty"`
ConfDataType string `protobuf:"bytes,7,opt,name=conf_data_type,json=confDataType,proto3" json:"conf_data_type,omitempty"`
ConfRequired bool `protobuf:"varint,8,opt,name=conf_required,json=confRequired,proto3" json:"conf_required,omitempty"`
// contains filtered or unexported fields
}
func (*CollectorGroupConfigurations) Descriptor
deprecated
func (*CollectorGroupConfigurations) Descriptor() ([]byte, []int)
Deprecated: Use CollectorGroupConfigurations.ProtoReflect.Descriptor instead.
func (*CollectorGroupConfigurations) GetConfDataType ¶
func (x *CollectorGroupConfigurations) GetConfDataType() string
func (*CollectorGroupConfigurations) GetConfDescription ¶
func (x *CollectorGroupConfigurations) GetConfDescription() string
func (*CollectorGroupConfigurations) GetConfKey ¶
func (x *CollectorGroupConfigurations) GetConfKey() string
func (*CollectorGroupConfigurations) GetConfName ¶
func (x *CollectorGroupConfigurations) GetConfName() string
func (*CollectorGroupConfigurations) GetConfRequired ¶
func (x *CollectorGroupConfigurations) GetConfRequired() bool
func (*CollectorGroupConfigurations) GetConfValue ¶
func (x *CollectorGroupConfigurations) GetConfValue() string
func (*CollectorGroupConfigurations) GetGroupId ¶
func (x *CollectorGroupConfigurations) GetGroupId() int32
func (*CollectorGroupConfigurations) GetId ¶
func (x *CollectorGroupConfigurations) GetId() int32
func (*CollectorGroupConfigurations) ProtoMessage ¶
func (*CollectorGroupConfigurations) ProtoMessage()
func (*CollectorGroupConfigurations) ProtoReflect ¶
func (x *CollectorGroupConfigurations) ProtoReflect() protoreflect.Message
func (*CollectorGroupConfigurations) Reset ¶
func (x *CollectorGroupConfigurations) Reset()
func (*CollectorGroupConfigurations) String ¶
func (x *CollectorGroupConfigurations) String() string
type CollectorMessages ¶
type CollectorMessages struct {
// Types that are valid to be assigned to StreamMessage:
//
// *CollectorMessages_Config
// *CollectorMessages_Result
StreamMessage isCollectorMessages_StreamMessage `protobuf_oneof:"stream_message"`
// contains filtered or unexported fields
}
func (*CollectorMessages) Descriptor
deprecated
func (*CollectorMessages) Descriptor() ([]byte, []int)
Deprecated: Use CollectorMessages.ProtoReflect.Descriptor instead.
func (*CollectorMessages) GetConfig ¶
func (x *CollectorMessages) GetConfig() *CollectorConfig
func (*CollectorMessages) GetResult ¶
func (x *CollectorMessages) GetResult() *ConfigKnowledge
func (*CollectorMessages) GetStreamMessage ¶
func (x *CollectorMessages) GetStreamMessage() isCollectorMessages_StreamMessage
func (*CollectorMessages) ProtoMessage ¶
func (*CollectorMessages) ProtoMessage()
func (*CollectorMessages) ProtoReflect ¶
func (x *CollectorMessages) ProtoReflect() protoreflect.Message
func (*CollectorMessages) Reset ¶
func (x *CollectorMessages) Reset()
func (*CollectorMessages) String ¶
func (x *CollectorMessages) String() string
type CollectorMessages_Config ¶
type CollectorMessages_Config struct {
Config *CollectorConfig `protobuf:"bytes,1,opt,name=config,proto3,oneof"`
}
type CollectorMessages_Result ¶
type CollectorMessages_Result struct {
Result *ConfigKnowledge `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}
type CollectorModule ¶
type CollectorModule int32
const ( CollectorModule_AS_400 CollectorModule = 0 CollectorModule_UTMSTACK CollectorModule = 1 )
func (CollectorModule) Descriptor ¶
func (CollectorModule) Descriptor() protoreflect.EnumDescriptor
func (CollectorModule) Enum ¶
func (x CollectorModule) Enum() *CollectorModule
func (CollectorModule) EnumDescriptor
deprecated
func (CollectorModule) EnumDescriptor() ([]byte, []int)
Deprecated: Use CollectorModule.Descriptor instead.
func (CollectorModule) Number ¶
func (x CollectorModule) Number() protoreflect.EnumNumber
func (CollectorModule) String ¶
func (x CollectorModule) String() string
func (CollectorModule) Type ¶
func (CollectorModule) Type() protoreflect.EnumType
type CollectorServiceClient ¶
type CollectorServiceClient interface {
RegisterCollector(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*AuthResponse, error)
DeleteCollector(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*AuthResponse, error)
ListCollector(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListCollectorResponse, error)
CollectorStream(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[CollectorMessages, CollectorMessages], error)
GetCollectorConfig(ctx context.Context, in *ConfigRequest, opts ...grpc.CallOption) (*CollectorConfig, error)
}
CollectorServiceClient is the client API for CollectorService 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 NewCollectorServiceClient ¶
func NewCollectorServiceClient(cc grpc.ClientConnInterface) CollectorServiceClient
type CollectorServiceServer ¶
type CollectorServiceServer interface {
RegisterCollector(context.Context, *RegisterRequest) (*AuthResponse, error)
DeleteCollector(context.Context, *DeleteRequest) (*AuthResponse, error)
ListCollector(context.Context, *ListRequest) (*ListCollectorResponse, error)
CollectorStream(grpc.BidiStreamingServer[CollectorMessages, CollectorMessages]) error
GetCollectorConfig(context.Context, *ConfigRequest) (*CollectorConfig, error)
// contains filtered or unexported methods
}
CollectorServiceServer is the server API for CollectorService service. All implementations must embed UnimplementedCollectorServiceServer for forward compatibility.
type CollectorService_CollectorStreamClient ¶
type CollectorService_CollectorStreamClient = grpc.BidiStreamingClient[CollectorMessages, CollectorMessages]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type CollectorService_CollectorStreamServer ¶
type CollectorService_CollectorStreamServer = grpc.BidiStreamingServer[CollectorMessages, CollectorMessages]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type ConfigKnowledge ¶
type ConfigKnowledge struct {
Accepted string `protobuf:"bytes,1,opt,name=accepted,proto3" json:"accepted,omitempty"`
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigKnowledge) Descriptor
deprecated
func (*ConfigKnowledge) Descriptor() ([]byte, []int)
Deprecated: Use ConfigKnowledge.ProtoReflect.Descriptor instead.
func (*ConfigKnowledge) GetAccepted ¶
func (x *ConfigKnowledge) GetAccepted() string
func (*ConfigKnowledge) GetRequestId ¶
func (x *ConfigKnowledge) GetRequestId() string
func (*ConfigKnowledge) ProtoMessage ¶
func (*ConfigKnowledge) ProtoMessage()
func (*ConfigKnowledge) ProtoReflect ¶
func (x *ConfigKnowledge) ProtoReflect() protoreflect.Message
func (*ConfigKnowledge) Reset ¶
func (x *ConfigKnowledge) Reset()
func (*ConfigKnowledge) String ¶
func (x *ConfigKnowledge) String() string
type ConfigRequest ¶
type ConfigRequest struct {
Module CollectorModule `protobuf:"varint,1,opt,name=module,proto3,enum=agent.CollectorModule" json:"module,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigRequest) Descriptor
deprecated
func (*ConfigRequest) Descriptor() ([]byte, []int)
Deprecated: Use ConfigRequest.ProtoReflect.Descriptor instead.
func (*ConfigRequest) GetModule ¶
func (x *ConfigRequest) GetModule() CollectorModule
func (*ConfigRequest) ProtoMessage ¶
func (*ConfigRequest) ProtoMessage()
func (*ConfigRequest) ProtoReflect ¶
func (x *ConfigRequest) ProtoReflect() protoreflect.Message
func (*ConfigRequest) Reset ¶
func (x *ConfigRequest) Reset()
func (*ConfigRequest) String ¶
func (x *ConfigRequest) String() string
type ConnectorType ¶
type ConnectorType int32
const ( ConnectorType_AGENT ConnectorType = 0 ConnectorType_COLLECTOR ConnectorType = 1 )
func (ConnectorType) Descriptor ¶
func (ConnectorType) Descriptor() protoreflect.EnumDescriptor
func (ConnectorType) Enum ¶
func (x ConnectorType) Enum() *ConnectorType
func (ConnectorType) EnumDescriptor
deprecated
func (ConnectorType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConnectorType.Descriptor instead.
func (ConnectorType) Number ¶
func (x ConnectorType) Number() protoreflect.EnumNumber
func (ConnectorType) String ¶
func (x ConnectorType) String() string
func (ConnectorType) Type ¶
func (ConnectorType) Type() protoreflect.EnumType
type DeleteRequest ¶
type DeleteRequest struct {
DeletedBy string `protobuf:"bytes,1,opt,name=deleted_by,json=deletedBy,proto3" json:"deleted_by,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteRequest) Descriptor
deprecated
func (*DeleteRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRequest.ProtoReflect.Descriptor instead.
func (*DeleteRequest) GetDeletedBy ¶
func (x *DeleteRequest) GetDeletedBy() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) ProtoReflect ¶
func (x *DeleteRequest) ProtoReflect() protoreflect.Message
func (*DeleteRequest) Reset ¶
func (x *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (x *DeleteRequest) String() string
type ListCollectorResponse ¶
type ListCollectorResponse struct {
Rows []*Collector `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
Total int32 `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
// contains filtered or unexported fields
}
func (*ListCollectorResponse) Descriptor
deprecated
func (*ListCollectorResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListCollectorResponse.ProtoReflect.Descriptor instead.
func (*ListCollectorResponse) GetRows ¶
func (x *ListCollectorResponse) GetRows() []*Collector
func (*ListCollectorResponse) GetTotal ¶
func (x *ListCollectorResponse) GetTotal() int32
func (*ListCollectorResponse) ProtoMessage ¶
func (*ListCollectorResponse) ProtoMessage()
func (*ListCollectorResponse) ProtoReflect ¶
func (x *ListCollectorResponse) ProtoReflect() protoreflect.Message
func (*ListCollectorResponse) Reset ¶
func (x *ListCollectorResponse) Reset()
func (*ListCollectorResponse) String ¶
func (x *ListCollectorResponse) String() string
type ListRequest ¶
type ListRequest struct {
PageNumber int32 `protobuf:"varint,1,opt,name=page_number,json=pageNumber,proto3" json:"page_number,omitempty"`
PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
SearchQuery string `protobuf:"bytes,3,opt,name=search_query,json=searchQuery,proto3" json:"search_query,omitempty"`
SortBy string `protobuf:"bytes,4,opt,name=sort_by,json=sortBy,proto3" json:"sort_by,omitempty"`
// contains filtered or unexported fields
}
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetPageNumber ¶
func (x *ListRequest) GetPageNumber() int32
func (*ListRequest) GetPageSize ¶
func (x *ListRequest) GetPageSize() int32
func (*ListRequest) GetSearchQuery ¶
func (x *ListRequest) GetSearchQuery() string
func (*ListRequest) GetSortBy ¶
func (x *ListRequest) GetSortBy() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type PanelCollectorServiceClient ¶
type PanelCollectorServiceClient interface {
RegisterCollectorConfig(ctx context.Context, in *CollectorConfig, opts ...grpc.CallOption) (*ConfigKnowledge, error)
}
PanelCollectorServiceClient is the client API for PanelCollectorService 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 NewPanelCollectorServiceClient ¶
func NewPanelCollectorServiceClient(cc grpc.ClientConnInterface) PanelCollectorServiceClient
type PanelCollectorServiceServer ¶
type PanelCollectorServiceServer interface {
RegisterCollectorConfig(context.Context, *CollectorConfig) (*ConfigKnowledge, error)
// contains filtered or unexported methods
}
PanelCollectorServiceServer is the server API for PanelCollectorService service. All implementations must embed UnimplementedPanelCollectorServiceServer for forward compatibility.
type PingRequest ¶
type PingRequest struct {
Type ConnectorType `protobuf:"varint,1,opt,name=type,proto3,enum=agent.ConnectorType" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*PingRequest) Descriptor
deprecated
func (*PingRequest) Descriptor() ([]byte, []int)
Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.
func (*PingRequest) GetType ¶
func (x *PingRequest) GetType() ConnectorType
func (*PingRequest) ProtoMessage ¶
func (*PingRequest) ProtoMessage()
func (*PingRequest) ProtoReflect ¶
func (x *PingRequest) ProtoReflect() protoreflect.Message
func (*PingRequest) Reset ¶
func (x *PingRequest) Reset()
func (*PingRequest) String ¶
func (x *PingRequest) String() string
type PingResponse ¶
type PingResponse struct {
Received string `protobuf:"bytes,1,opt,name=received,proto3" json:"received,omitempty"`
// contains filtered or unexported fields
}
func (*PingResponse) Descriptor
deprecated
func (*PingResponse) Descriptor() ([]byte, []int)
Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.
func (*PingResponse) GetReceived ¶
func (x *PingResponse) GetReceived() string
func (*PingResponse) ProtoMessage ¶
func (*PingResponse) ProtoMessage()
func (*PingResponse) ProtoReflect ¶
func (x *PingResponse) ProtoReflect() protoreflect.Message
func (*PingResponse) Reset ¶
func (x *PingResponse) Reset()
func (*PingResponse) String ¶
func (x *PingResponse) String() string
type PingServiceClient ¶
type PingServiceClient interface {
Ping(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[PingRequest, PingResponse], error)
}
PingServiceClient is the client API for PingService 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 NewPingServiceClient ¶
func NewPingServiceClient(cc grpc.ClientConnInterface) PingServiceClient
type PingServiceServer ¶
type PingServiceServer interface {
Ping(grpc.ClientStreamingServer[PingRequest, PingResponse]) error
// contains filtered or unexported methods
}
PingServiceServer is the server API for PingService service. All implementations must embed UnimplementedPingServiceServer for forward compatibility.
type PingService_PingClient ¶
type PingService_PingClient = grpc.ClientStreamingClient[PingRequest, PingResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type PingService_PingServer ¶
type PingService_PingServer = grpc.ClientStreamingServer[PingRequest, PingResponse]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type RegisterRequest ¶
type RegisterRequest struct {
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
Hostname string `protobuf:"bytes,2,opt,name=hostname,proto3" json:"hostname,omitempty"`
Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
Collector CollectorModule `protobuf:"varint,4,opt,name=collector,proto3,enum=agent.CollectorModule" json:"collector,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterRequest) Descriptor
deprecated
func (*RegisterRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.
func (*RegisterRequest) GetCollector ¶
func (x *RegisterRequest) GetCollector() CollectorModule
func (*RegisterRequest) GetHostname ¶
func (x *RegisterRequest) GetHostname() string
func (*RegisterRequest) GetIp ¶
func (x *RegisterRequest) GetIp() string
func (*RegisterRequest) GetVersion ¶
func (x *RegisterRequest) GetVersion() string
func (*RegisterRequest) ProtoMessage ¶
func (*RegisterRequest) ProtoMessage()
func (*RegisterRequest) ProtoReflect ¶
func (x *RegisterRequest) ProtoReflect() protoreflect.Message
func (*RegisterRequest) Reset ¶
func (x *RegisterRequest) Reset()
func (*RegisterRequest) String ¶
func (x *RegisterRequest) String() string
type Status ¶
type Status int32
func (Status) Descriptor ¶
func (Status) Descriptor() protoreflect.EnumDescriptor
func (Status) EnumDescriptor
deprecated
func (Status) Number ¶
func (x Status) Number() protoreflect.EnumNumber
func (Status) Type ¶
func (Status) Type() protoreflect.EnumType
type UnimplementedCollectorServiceServer ¶
type UnimplementedCollectorServiceServer struct{}
UnimplementedCollectorServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedCollectorServiceServer) CollectorStream ¶
func (UnimplementedCollectorServiceServer) CollectorStream(grpc.BidiStreamingServer[CollectorMessages, CollectorMessages]) error
func (UnimplementedCollectorServiceServer) DeleteCollector ¶
func (UnimplementedCollectorServiceServer) DeleteCollector(context.Context, *DeleteRequest) (*AuthResponse, error)
func (UnimplementedCollectorServiceServer) GetCollectorConfig ¶
func (UnimplementedCollectorServiceServer) GetCollectorConfig(context.Context, *ConfigRequest) (*CollectorConfig, error)
func (UnimplementedCollectorServiceServer) ListCollector ¶
func (UnimplementedCollectorServiceServer) ListCollector(context.Context, *ListRequest) (*ListCollectorResponse, error)
func (UnimplementedCollectorServiceServer) RegisterCollector ¶
func (UnimplementedCollectorServiceServer) RegisterCollector(context.Context, *RegisterRequest) (*AuthResponse, error)
type UnimplementedPanelCollectorServiceServer ¶
type UnimplementedPanelCollectorServiceServer struct{}
UnimplementedPanelCollectorServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedPanelCollectorServiceServer) RegisterCollectorConfig ¶
func (UnimplementedPanelCollectorServiceServer) RegisterCollectorConfig(context.Context, *CollectorConfig) (*ConfigKnowledge, error)
type UnimplementedPingServiceServer ¶
type UnimplementedPingServiceServer struct{}
UnimplementedPingServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
type UnsafeCollectorServiceServer ¶
type UnsafeCollectorServiceServer interface {
// contains filtered or unexported methods
}
UnsafeCollectorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CollectorServiceServer will result in compilation errors.
type UnsafePanelCollectorServiceServer ¶
type UnsafePanelCollectorServiceServer interface {
// contains filtered or unexported methods
}
UnsafePanelCollectorServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PanelCollectorServiceServer will result in compilation errors.
type UnsafePingServiceServer ¶
type UnsafePingServiceServer interface {
// contains filtered or unexported methods
}
UnsafePingServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to PingServiceServer will result in compilation errors.