gnetwire

Documentation

Index

• Constants
• Variables
• func NewClient(netw, addr string) *fastrpc.Client
• func NewClientWithDial(addr string, dial func(addr string) (net.Conn, error)) *fastrpc.Client
• func NewServer(MS MultiStorage) *fastrpc.Server
• type Client
  • func (c Client) StoreReadMessage(id []byte, over, head, body bool) (bufferex.Binary, error)
  • func (c Client) StoreWriteMessage(id, msg []byte, expire uint64) error
  • func (c Client) String() string
• type MultiStorage

Constants

const ProtocolVersion byte = 1

const SniffHeader = "shardSTORE"

Variables

var ENoResponse = fmt.Errorf("NoResponse")

Functions

func NewClient

func NewClient(netw, addr string) *fastrpc.Client

func NewClientWithDial

func NewClientWithDial(addr string, dial func(addr string) (net.Conn, error)) *fastrpc.Client

func NewServer

func NewServer(MS MultiStorage) *fastrpc.Server

Types

type Client

type Client struct {
	Cli    *fastrpc.Client
	K1, K2 string
}

func (Client) StoreReadMessage

func (c Client) StoreReadMessage(id []byte, over, head, body bool) (bufferex.Binary, error)

func (Client) StoreWriteMessage

func (c Client) StoreWriteMessage(id, msg []byte, expire uint64) error

func (Client) String

func (c Client) String() string

type MultiStorage

type MultiStorage interface {
	Lookup(K1, K2 []byte) articlestore.Storage
}