agent

package
v0.0.0-...-720764a Latest Latest
Warning

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

Go to latest
Published: Oct 28, 2026 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

View Source
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"
)
View Source
const (
	PanelCollectorService_RegisterCollectorConfig_FullMethodName = "/agent.PanelCollectorService/RegisterCollectorConfig"
)
View Source
const (
	PingService_Ping_FullMethodName = "/agent.PingService/Ping"
)

Variables

View Source
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.

View Source
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.

View Source
var (
	ConnectorType_name = map[int32]string{
		0: "AGENT",
		1: "COLLECTOR",
	}
	ConnectorType_value = map[string]int32{
		"AGENT":     0,
		"COLLECTOR": 1,
	}
)

Enum value maps for ConnectorType.

View Source
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)

View Source
var File_collector_proto protoreflect.FileDescriptor
View Source
var File_common_proto protoreflect.FileDescriptor
View Source
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)

View Source
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 DeleteAgent(cnf *config.Config) error

func RegisterCollector

func RegisterCollector(cnf *config.Config, UTMKey string) error

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 StartPing

func StartPing(cnf *config.Config, ctx context.Context)

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) Descriptor() ([]byte, []int)

Deprecated: Use Collector.ProtoReflect.Descriptor instead.

func (*Collector) GetCollectorKey

func (x *Collector) GetCollectorKey() string

func (*Collector) GetHostname

func (x *Collector) GetHostname() string

func (*Collector) GetId

func (x *Collector) GetId() int32

func (*Collector) GetIp

func (x *Collector) GetIp() string

func (*Collector) GetLastSeen

func (x *Collector) GetLastSeen() string

func (*Collector) GetModule

func (x *Collector) GetModule() CollectorModule

func (*Collector) GetStatus

func (x *Collector) GetStatus() Status

func (*Collector) GetVersion

func (x *Collector) GetVersion() string

func (*Collector) ProtoMessage

func (*Collector) ProtoMessage()

func (*Collector) ProtoReflect

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

func (*Collector) Reset

func (x *Collector) Reset()

func (*Collector) String

func (x *Collector) String() string

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 (*CollectorGroupConfigurations) ProtoMessage

func (*CollectorGroupConfigurations) ProtoMessage()

func (*CollectorGroupConfigurations) ProtoReflect

func (*CollectorGroupConfigurations) Reset

func (x *CollectorGroupConfigurations) Reset()

func (*CollectorGroupConfigurations) 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) Enum

func (x CollectorModule) Enum() *CollectorModule

func (CollectorModule) EnumDescriptor deprecated

func (CollectorModule) EnumDescriptor() ([]byte, []int)

Deprecated: Use CollectorModule.Descriptor instead.

func (CollectorModule) Number

func (CollectorModule) String

func (x CollectorModule) String() string

func (CollectorModule) Type

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.

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) Enum

func (x ConnectorType) Enum() *ConnectorType

func (ConnectorType) EnumDescriptor deprecated

func (ConnectorType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ConnectorType.Descriptor instead.

func (ConnectorType) Number

func (ConnectorType) String

func (x ConnectorType) String() string

func (ConnectorType) Type

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.

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.

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
const (
	Status_ONLINE  Status = 0
	Status_OFFLINE Status = 1
	Status_UNKNOWN Status = 2
)

func (Status) Descriptor

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number

func (x Status) Number() protoreflect.EnumNumber

func (Status) String

func (x Status) String() string

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) DeleteCollector

func (UnimplementedCollectorServiceServer) GetCollectorConfig

func (UnimplementedCollectorServiceServer) ListCollector

func (UnimplementedCollectorServiceServer) RegisterCollector

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

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.

func (UnimplementedPingServiceServer) Ping

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL