Documentation
¶
Overview ¶
Package registration provides the Registration gRPC service implementation.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
ShardStorage storage.Storage // For shard-scoped writes (agent registration)
ClusterStorage storage.Storage // For cluster-scoped writes (operator registration)
SecretsStore secrets.Store
LocalDB *localdb.DB
InstanceManager *instances.Manager
ConfigLoader *config.Loader
IsShardLeader func() bool // For agent registration
IsClusterLeader func() bool // For operator registration
Logger *slog.Logger
}
Options contains options for creating a RegistrationService
type Service ¶
type Service struct {
proto.UnimplementedRegistrationServiceServer
// contains filtered or unexported fields
}
Service implements the RegistrationService gRPC service
func (*Service) RegisterAgent ¶
func (s *Service) RegisterAgent(ctx context.Context, req *proto.RegisterClientRequest) (*proto.RegisterClientResponse, error)
func (*Service) RegisterOperator ¶
func (s *Service) RegisterOperator(ctx context.Context, req *proto.RegisterClientRequest) (*proto.RegisterClientResponse, error)
Click to show internal directories.
Click to hide internal directories.