operator

type Backend ¶

type Backend interface {
	TransferLeader(ctx context.Context, request *pboperator.TransferLeaderRequest) (*pboperator.TransferLeaderResponse, error)
	ResolveTokenAndDefaultMeta(token string, entMeta *acl.EnterpriseMeta, authzCtx *acl.AuthorizerContext) (resolver.Result, error)
}

Backend defines the core integrations the Operator endpoint depends on. A functional implementation will integrate with various operator operation such as raft, autopilot operation. The only currently implemented operation is raft leader transfer

type Config ¶

type Config struct {
	Backend    Backend
	Logger     hclog.Logger
	ForwardRPC func(structs.RPCInfo, func(*grpc.ClientConn) error) (bool, error)
	Datacenter string
}

type Server ¶

type Server struct {
	Config
}

Server implements pboperator.OperatorService to provide RPC operations for managing operator operation.

func NewServer(cfg Config) *Server

func (s *Server) Register(grpcServer *grpc.Server)

func (s *Server) TransferLeader(ctx context.Context, request *pboperator.TransferLeaderRequest) (*pboperator.TransferLeaderResponse, error)