raid

Documentation

Index

• Constants
• func NewEtagContext(ctx context.Context) context.Context
• type Client
  • func NewClient(mode, addr string) (*Client, error)
  • func (c *Client) Conn() net.Conn
  • func (c *Client) Request(msg *Message) (chan *Message, error)
  • func (c *Client) Send(msg *Message) error
• type Etag
  • func EtagFromContext(ctx context.Context) (Etag, bool)
  • func NewEtag() Etag
  • func (e Etag) String() string
• type Message
  • func (m *Message) Action() string
  • func (m *Message) Etag() Etag

Constants

const (
	ReadBufferSize = 4 * 1024
)

Functions

func NewEtagContext

func NewEtagContext(ctx context.Context) context.Context

Types

type Client

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

func NewClient

func NewClient(mode, addr string) (*Client, error)

func (*Client) Conn

func (c *Client) Conn() net.Conn

func (*Client) Request

func (c *Client) Request(msg *Message) (chan *Message, error)

func (*Client) Send

func (c *Client) Send(msg *Message) error

type Etag

type Etag string

func EtagFromContext

func EtagFromContext(ctx context.Context) (Etag, bool)

func NewEtag

func NewEtag() Etag

func (Etag) String

func (e Etag) String() string

type Message

type Message struct {
	Header map[string]interface{} `json:"header"`
	Body   interface{}            `json:"body"`
}

func (*Message) Action

func (m *Message) Action() string

func (*Message) Etag

func (m *Message) Etag() Etag