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 Websocket
  • func NewWebsocket(config WebsocketConfig) *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)
• type WebsocketConfig

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 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
}

type MessageHandler

type MessageHandler func(m *rony.MessageEnvelope)

type Websocket

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

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) (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)

type WebsocketConfig

type WebsocketConfig 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
}