shared

Documentation

Index

• type Reader
• type ReaderPlugin
  • func (r *ReaderPlugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (r *ReaderPlugin) Server(broker *plugin.MuxBroker) (interface{}, error)
• type ReaderRPCClient
  • func (g *ReaderRPCClient) Read(key string) string
• type ReaderRPCServer
  • func (s *ReaderRPCServer) Read(mapArgs map[string]interface{}, resp *string) error
• type Writer
• type WriterPlugin
  • func (r *WriterPlugin) Client(broker *plugin.MuxBroker, c *rpc.Client) (interface{}, error)
  • func (r *WriterPlugin) Server(broker *plugin.MuxBroker) (interface{}, error)
• type WriterRPCClient
  • func (g *WriterRPCClient) Update(data []byte) string
• type WriterRPCServer
  • func (s *WriterRPCServer) Write(mapArgs map[string]interface{}, resp *string) error

Types

type Reader

type Reader interface {
	Read(key string) string
}

type ReaderPlugin

type ReaderPlugin struct {
	Impl Reader
}

func (*ReaderPlugin) Client

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

func (*ReaderPlugin) Server

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

type ReaderRPCClient

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

func (*ReaderRPCClient) Read

func (g *ReaderRPCClient) Read(key string) string

type ReaderRPCServer

type ReaderRPCServer struct {
	Impl Reader
}

func (*ReaderRPCServer) Read

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

type Writer

type Writer interface {
	Update(data []byte) string
}

type WriterPlugin

type WriterPlugin struct {
	Impl Writer
}

func (*WriterPlugin) Client

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

func (*WriterPlugin) Server

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

type WriterRPCClient

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

func (*WriterRPCClient) Update

func (g *WriterRPCClient) Update(data []byte) string

type WriterRPCServer

type WriterRPCServer struct {
	Impl Writer
}

func (*WriterRPCServer) Write

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