clustershim

Documentation

Overview

Package clustershim implements a grpc server for handling clustercontroller requests.

Index

• type ShimHandler
• type ShimServer
  • func NewShimServer() *ShimServer
  • func (s *ShimServer) Close()
  • func (s *ShimServer) ClusterName() string
  • func (s *ShimServer) Do(in *clustermessage.ClusterMessage) (*clustermessage.ClusterMessage, error)
  • func (s *ShimServer) DoControlMultiRequest(in *clustermessage.ClusterMessage) error
  • func (s *ShimServer) DoControlRequest(in *clustermessage.ClusterMessage) (*clustermessage.ClusterMessage, error)
  • func (s *ShimServer) RegisterHandler(name string, h handler.Handler)
  • func (s *ShimServer) SendChan() chan clustermessage.ClusterMessage
  • func (s *ShimServer) Serve(addr string) error
• type ShimServiceClient
  • func NewRemoteShimClient(shimClientName, addr string) ShimServiceClient
  • func NewlocalShimClient(c *config.ClusterControllerConfig) ShimServiceClient
  • func NewlocalShimClientWithHandler(handlers ShimHandler) ShimServiceClient

Types

type ShimHandler

type ShimHandler map[string]handler.Handler

ShimHandler is a handler map of a shim server. The key is Destination field in ShimRequest, and the value is the corresponding handler.

type ShimServer

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

ShimServer handles requests and transmits to corresponding shim handler.

func NewShimServer

func NewShimServer() *ShimServer

NewShimServer creates a new shimServer.

func (*ShimServer) Close

func (s *ShimServer) Close()

Close gracefully stops shim server.

func (*ShimServer) ClusterName

func (s *ShimServer) ClusterName() string

ClusterName returns the cluster name.

func (*ShimServer) Do

func (s *ShimServer) Do(in *clustermessage.ClusterMessage) (*clustermessage.ClusterMessage, error)

Do handles the requests and transmits to corresponding server.

func (*ShimServer) DoControlMultiRequest

func (s *ShimServer) DoControlMultiRequest(in *clustermessage.ClusterMessage) error

func (*ShimServer) DoControlRequest

func (s *ShimServer) DoControlRequest(in *clustermessage.ClusterMessage) (*clustermessage.ClusterMessage, error)

func (*ShimServer) RegisterHandler

func (s *ShimServer) RegisterHandler(name string, h handler.Handler)

RegisterHandler registers shim handler.

func (*ShimServer) SendChan

func (s *ShimServer) SendChan() chan clustermessage.ClusterMessage

SendChan returns the channel that save messages need to be reported.

func (*ShimServer) Serve

func (s *ShimServer) Serve(addr string) error

Serve starts a grpc server over unix socket.

type ShimServiceClient

type ShimServiceClient interface {
	Do(in *clustermessage.ClusterMessage) (*clustermessage.ClusterMessage, error)
	ReturnChan() <-chan *clustermessage.ClusterMessage
}

ShimServiceClient is the client interface to a cluster shim.

func NewRemoteShimClient

func NewRemoteShimClient(shimClientName, addr string) ShimServiceClient

NewRemoteShimClient returns a remote shim client which is connecting to addr.

func NewlocalShimClient

func NewlocalShimClient(c *config.ClusterControllerConfig) ShimServiceClient

NewlocalShimClient returns a local shim client with default handler.

func NewlocalShimClientWithHandler

func NewlocalShimClientWithHandler(handlers ShimHandler) ShimServiceClient

NewlocalShimClientWithHandler returns a local shim client with given handlers.