manager

Documentation

Index

• func Adapt(rpcClient rpc_client.Client) manager.Manager
• func NewClient(socketPath string) (manager.Manager, error)
• type IsLeaderRequest
• type IsLeaderResponse
• type Manager
  • func PluginServer(p manager.Manager) *Manager
  • func (p *Manager) ImplementedInterface() spi.InterfaceSpec
  • func (p *Manager) IsLeader(_ *http.Request, req *IsLeaderRequest, resp *IsLeaderResponse) error

Functions

func Adapt

func Adapt(rpcClient rpc_client.Client) manager.Manager

Adapt converts a rpc client to a Manager object

func NewClient

func NewClient(socketPath string) (manager.Manager, error)

NewClient returns a plugin interface implementation connected to a remote plugin

Types

type IsLeaderRequest

type IsLeaderRequest struct {
}

IsLeaderRequest is the rpc request

type IsLeaderResponse

type IsLeaderResponse struct {
	Leader bool
}

IsLeaderResponse is the rpc response

type Manager

type Manager struct {
	// contains filtered or unexported fields
}

Manager is the exported type for json-rpc

func PluginServer

func PluginServer(p manager.Manager) *Manager

PluginServer returns a Manager that conforms to the net/rpc rpc call convention.

func (*Manager) ImplementedInterface

func (p *Manager) ImplementedInterface() spi.InterfaceSpec

ImplementedInterface returns the interface implemented by this RPC service.

func (*Manager) IsLeader

func (p *Manager) IsLeader(_ *http.Request, req *IsLeaderRequest, resp *IsLeaderResponse) error

IsLeader returns information about leadership status for this manager.