edgec

Documentation

Index

• Variables
• type Client
• type Config
• type MessageHandler
• type Websocket
  • func NewWebsocket(config Config) *Websocket
  • func (c *Websocket) Close() error
  • func (c *Websocket) GetRequestID() uint64
  • func (c *Websocket) Send(req, res *rony.MessageEnvelope) (err error)
  • func (c *Websocket) SendWithContext(ctx context.Context, req, res *rony.MessageEnvelope) (err error)
  • func (c *Websocket) SendWithDetails(ctx context.Context, req, res *rony.MessageEnvelope, waitToConnect bool, ...) (err error)

Variables

var (
	ErrTimeout        = fmt.Errorf("time out")
	ErrLeaderRedirect = fmt.Errorf("leader redirect")
)

Types

type Client

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

type Config

type Config struct {
	HostPort     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
}

type MessageHandler

type MessageHandler func(m *rony.MessageEnvelope)

type Websocket

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

func NewWebsocket

func NewWebsocket(config Config) *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) (err error)

func (*Websocket) SendWithContext

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

func (*Websocket) SendWithDetails

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