Versions in this module Expand all Collapse all v0 v0.1.0 Nov 28, 2019 Changes in this version + type ShimHandler map[string]handler.Handler + type ShimServer struct + 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 interface + Do func(in *clustermessage.ClusterMessage) (*clustermessage.ClusterMessage, error) + ReturnChan func() <-chan *clustermessage.ClusterMessage + func NewRemoteShimClient(shimClientName, addr string) ShimServiceClient + func NewlocalShimClient(c *config.ClusterControllerConfig) ShimServiceClient + func NewlocalShimClientWithHandler(handlers ShimHandler) ShimServiceClient
Go to main page