client

Documentation

Index

• Constants
• type Client
  • func NewClient(networkId uint64, chainId uint64, conn *nats.Conn, js nats.JetStreamContext, ...) Client
  • func (c *Client) Init(ctx context.Context) error
  • func (c *Client) Invoke(ctx context.Context, req *pjrpc.Request, resp *pjrpc.Response) error
• type Handler
• type Router
  • func NewRouter(conn *nats.Conn, ht *tracking.HeadTracker, subjectPrefix string, ...) Router
  • func (r *Router) Route(ctx context.Context, req *pjrpc.Request, resp *pjrpc.Response)

Constants

const (
	ErrEmptyParams        = errors.ConstError("empty params")
	ErrInsufficientParams = errors.ConstError("insufficient params")
	ErrHeadUnavailable    = errors.ConstError("latest head is not available")
)

const (
	ErrUnsupportedMethod = errors.ConstError("unsupported method")
)

Types

type Client

type Client struct {
	NetworkId uint64
	ChainId   uint64
	// contains filtered or unexported fields
}

func NewClient

func NewClient(networkId uint64, chainId uint64, conn *nats.Conn, js nats.JetStreamContext, log *zap.Logger) Client

func (*Client) Init

func (c *Client) Init(ctx context.Context) error

func (*Client) Invoke

func (c *Client) Invoke(ctx context.Context, req *pjrpc.Request, resp *pjrpc.Response) error

type Handler

type Handler = func(ctx context.Context, req *pjrpc.Request, resp *pjrpc.Response)

type Router

type Router struct {
	SubjectPrefix string
	// contains filtered or unexported fields
}

func NewRouter

func NewRouter(conn *nats.Conn, ht *tracking.HeadTracker, subjectPrefix string, log *zap.Logger) Router

func (*Router) Route

func (r *Router) Route(ctx context.Context, req *pjrpc.Request, resp *pjrpc.Response)