client

Documentation

Index

• type Client
  • func NewClient(opts ...Option) (Client, error)
  • func NewTcpClient(opts ...Option) (Client, error)
• type Option
  • func WithAddress(addr string) Option
  • func WithCodec(c codec.Codec) Option
  • func WithMaxRetries(retries int) Option
  • func WithTimeout(timeout time.Duration) Option
• type Options

Types

type Client

type Client interface {
	Init(opts ...Option) error
	Options() Options
	Out() chan *codec.Packet
	Send(data interface{}) error
	Recv(out interface{}) error
	Read()
	Close() error
	String() string
}

func NewClient

func NewClient(opts ...Option) (Client, error)

func NewTcpClient

func NewTcpClient(opts ...Option) (Client, error)

type Option

type Option func(o *Options)

func WithAddress

func WithAddress(addr string) Option

func WithCodec

func WithCodec(c codec.Codec) Option

func WithMaxRetries

func WithMaxRetries(retries int) Option

func WithTimeout

func WithTimeout(timeout time.Duration) Option

type Options

type Options struct {
	Address    string
	MaxRetries int
	Timeout    time.Duration
	Codec      codec.Codec
}