edgec

Documentation

Index

• Variables
• type Client
• type Http
  • func NewHttp(config HttpConfig) *Http
  • func (h *Http) Close() error
  • func (h *Http) GetRequestID() uint64
  • func (h *Http) Send(req *rony.MessageEnvelope, res *rony.MessageEnvelope) (err error)
• type HttpConfig
• type MessageHandler
• type Router
• type Websocket
  • func NewWebsocket(config WebsocketConfig) *Websocket
  • func (c *Websocket) Close() error
  • func (c *Websocket) GetRequestID() uint64
  • func (c *Websocket) Send(req, res *rony.MessageEnvelope, leaderOnly bool) (err error)
  • func (c *Websocket) SendWithContext(ctx context.Context, req, res *rony.MessageEnvelope, leaderOnly bool) (err error)
  • func (c *Websocket) SendWithDetails(ctx context.Context, req, res *rony.MessageEnvelope, waitToConnect bool, ...) (err error)
  • func (c *Websocket) Start() error
• type WebsocketConfig

Variables

var (
	ErrNoConnection      = fmt.Errorf("no connection")
	ErrTimeout           = fmt.Errorf("time out")
	ErrReplicaMaster     = fmt.Errorf("leader redirect")
	ErrReplicaSetSession = fmt.Errorf("replica redirect session")
	ErrReplicaSetRequest = fmt.Errorf("replica redirect request")
	ErrUnknownResponse   = fmt.Errorf("unknown response")
)

Types

type Client

type Client interface {
	Send(req, res *rony.MessageEnvelope, leaderOnly bool) error
	Close() error
	GetRequestID() uint64
}

type Http

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

func NewHttp

func NewHttp(config HttpConfig) *Http

func (*Http) Close

func (h *Http) Close() error

func (*Http) GetRequestID

func (h *Http) GetRequestID() uint64

func (*Http) Send

func (h *Http) Send(req *rony.MessageEnvelope, res *rony.MessageEnvelope) (err error)

type HttpConfig

type HttpConfig struct {
	Name         string
	HostPort     string
	Header       map[string]string
	ReadTimeout  time.Duration
	WriteTimeout time.Duration
	Retries      int
}

type MessageHandler

type MessageHandler func(m *rony.MessageEnvelope)

type Router

type Router interface {
	UpdateRoute(req *rony.MessageEnvelope, replicaSet uint64)
	GetRoute(req *rony.MessageEnvelope) (replicaSet uint64)
}

type Websocket

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

Websocket client which could handle multiple connections

func NewWebsocket

func NewWebsocket(config WebsocketConfig) *Websocket

func (*Websocket) Close

func (c *Websocket) Close() error

func (*Websocket) GetRequestID

func (c *Websocket) GetRequestID() uint64

func (*Websocket) Send

func (c *Websocket) Send(req, res *rony.MessageEnvelope, leaderOnly bool) (err error)

func (*Websocket) SendWithContext

func (c *Websocket) SendWithContext(ctx context.Context, req, res *rony.MessageEnvelope, leaderOnly bool) (err error)

func (*Websocket) SendWithDetails

func (c *Websocket) SendWithDetails(
	ctx context.Context, req, res *rony.MessageEnvelope,
	waitToConnect bool, retry int, timeout time.Duration,
	leaderOnly bool,
) (err error)

func (*Websocket) Start

func (c *Websocket) Start() error

type WebsocketConfig

type WebsocketConfig struct {
	SeedHostPort string
	IdleTimeout  time.Duration
	DialTimeout  time.Duration
	Handler      MessageHandler
	Header       map[string]string
	Secure       bool
	ForceConnect bool
	// RequestMaxRetry is the maximum number client sends a request if any network layer error occurs
	RequestMaxRetry int
	// RequestTimeout is the timeout for each individual request on each try.
	RequestTimeout time.Duration
	// ContextTimeout is the amount that Send function will wait until times out. This includes all the retries.
	ContextTimeout time.Duration
	Router         Router
}

WebsocketConfig holds the configs for the Websocket client