rpc

Documentation

Index

• Constants
• func RespondWithError(msg *nats.Msg, err error) error
• type Handlers
  • func NewHandlers(log *zap.Logger, conn *nats.Conn, session *web3.Session, endpointPrefix string, ...) (*Handlers, error)
  • func (r *Handlers) ClientSubject() string
  • func (r *Handlers) HandleMsgs() error
  • func (r *Handlers) Init() error
  • func (r *Handlers) Prune() (err error)
  • func (r *Handlers) Register(block *web3.BlockHeader) error
  • func (r *Handlers) Shutdown() error
• type Option
  • func Concurrency(concurrency int) Option
  • func QueueName(name string) Option
• type Options
  • func GetDefaultOptions() Options

Constants

const (
	HeaderMethod = "method"
	HeaderErr    = "error"

	ErrMethodHeaderNotFound = errors.ConstError("method header not found")
)

Functions

func RespondWithError

func RespondWithError(msg *nats.Msg, err error) error

Types

type Handlers

type Handlers struct {
	Options Options
	// contains filtered or unexported fields
}

func NewHandlers

func NewHandlers(
	log *zap.Logger,
	conn *nats.Conn,
	session *web3.Session,
	endpointPrefix string,
	blockIndex *storage.BlockIndex,
	handler func(msg *nats.Msg),
	options ...Option) (*Handlers, error)

func (*Handlers) ClientSubject

func (r *Handlers) ClientSubject() string

func (*Handlers) HandleMsgs

func (r *Handlers) HandleMsgs() error

func (*Handlers) Init

func (r *Handlers) Init() error

func (*Handlers) Prune

func (r *Handlers) Prune() (err error)

func (*Handlers) Register

func (r *Handlers) Register(block *web3.BlockHeader) error

func (*Handlers) Shutdown

func (r *Handlers) Shutdown() error

type Option

type Option func(opts *Options) error

func Concurrency

func Concurrency(concurrency int) Option

func QueueName

func QueueName(name string) Option

type Options

type Options struct {
	Concurrency int
	QueueName   string
}

func GetDefaultOptions

func GetDefaultOptions() Options