agent

Documentation

Index

• func Command() (cli.Command, error)
• func RunAgent(ctx context.Context, config *protoconf_agent_config.AgentConfig) error
• type ProtoconfKVAgent
  • func NewProtoconfKVAgent(store store.Store, config *protoconf_agent_config.AgentConfig) (*ProtoconfKVAgent, error)
  • func (s *ProtoconfKVAgent) SubscribeForConfig(request *protoconf_pb.ConfigSubscriptionRequest, ...) error
• type ProtoconfKVAgentRollout
  • func NewProtoconfKVAgentRollout(store store.Store, config *protoconf_agent_config.AgentConfig) (*ProtoconfKVAgentRollout, error)
  • func (s *ProtoconfKVAgentRollout) SubscribeForConfig(request *protoconfservice.ConfigSubscriptionRequest, ...) error

Functions

func Command

func Command() (cli.Command, error)

Command is a cli.CommandFactory

func RunAgent

func RunAgent(ctx context.Context, config *protoconf_agent_config.AgentConfig) error

Types

type ProtoconfKVAgent

type ProtoconfKVAgent struct {
	Logger *slog.Logger
	protoconf_pb.ProtoconfServiceServer
	// contains filtered or unexported fields
}

func NewProtoconfKVAgent

func NewProtoconfKVAgent(store store.Store, config *protoconf_agent_config.AgentConfig) (*ProtoconfKVAgent, error)

func (*ProtoconfKVAgent) SubscribeForConfig

func (s *ProtoconfKVAgent) SubscribeForConfig(request *protoconf_pb.ConfigSubscriptionRequest, srv protoconf_pb.ProtoconfService_SubscribeForConfigServer) error

type ProtoconfKVAgentRollout

type ProtoconfKVAgentRollout struct {
	Logger *slog.Logger

	protoconfservice.ProtoconfServiceServer
	// contains filtered or unexported fields
}

func NewProtoconfKVAgentRollout

func NewProtoconfKVAgentRollout(store store.Store, config *protoconf_agent_config.AgentConfig) (*ProtoconfKVAgentRollout, error)

func (*ProtoconfKVAgentRollout) SubscribeForConfig

func (s *ProtoconfKVAgentRollout) SubscribeForConfig(request *protoconfservice.ConfigSubscriptionRequest, srv protoconfservice.ProtoconfService_SubscribeForConfigServer) error