operator

Documentation

Index

• type Backend
• type Config
• type Server
  • 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)

Types

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

func NewServer(cfg Config) *Server

func (*Server) Register

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

func (*Server) TransferLeader

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