shared

Documentation

Index

• type Deleter
• type DeleterPlugin
  • func (r *DeleterPlugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (r *DeleterPlugin) Server(broker *plugin.MuxBroker) (interface{}, error)
• type DeleterRPCClient
  • func (g *DeleterRPCClient) Delete(key string) string
• type DeleterRPCServer
  • func (s *DeleterRPCServer) Delete(mapArgs map[string]interface{}, resp *string) error
• type Updater
• type UpdaterPlugin
  • func (r *UpdaterPlugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (r *UpdaterPlugin) Server(broker *plugin.MuxBroker) (interface{}, error)
• type UpdaterRPCClient
  • func (g *UpdaterRPCClient) Update(data map[string]interface{}) string
• type UpdaterRPCServer
  • func (s *UpdaterRPCServer) Update(mapArgs map[string]interface{}, resp *string) error

Types

type Deleter

type Deleter interface {
	Delete(key string) string
}

type DeleterPlugin

type DeleterPlugin struct {
	Impl Deleter
}

func (*DeleterPlugin) Client

func (r *DeleterPlugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*DeleterPlugin) Server

func (r *DeleterPlugin) Server(broker *plugin.MuxBroker) (interface{}, error)

type DeleterRPCClient

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

func (*DeleterRPCClient) Delete

func (g *DeleterRPCClient) Delete(key string) string

type DeleterRPCServer

type DeleterRPCServer struct {
	Impl Deleter
}

func (*DeleterRPCServer) Delete

func (s *DeleterRPCServer) Delete(mapArgs map[string]interface{}, resp *string) error

type Updater

type Updater interface {
	Update(key, value string) string
}

type UpdaterPlugin

type UpdaterPlugin struct {
	Impl Updater
}

func (*UpdaterPlugin) Client

func (r *UpdaterPlugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)

func (*UpdaterPlugin) Server

func (r *UpdaterPlugin) Server(broker *plugin.MuxBroker) (interface{}, error)

type UpdaterRPCClient

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

func (*UpdaterRPCClient) Update

func (g *UpdaterRPCClient) Update(data map[string]interface{}) string

type UpdaterRPCServer

type UpdaterRPCServer struct {
	Impl Updater
}

func (*UpdaterRPCServer) Update

func (s *UpdaterRPCServer) Update(mapArgs map[string]interface{}, resp *string) error