sidecar

Documentation

Index

• Constants
• Variables
• type Option
  • func ClientId(id string) Option
  • func ClientUrl(url string) Option
  • func DataDir(path string) Option
  • func NatsEndpointPrefix(prefix string) Option
  • func NatsUrl(url string) Option
  • func RpcDenyList(deny []string) Option
  • func RpcHistorySize(size int) Option
• type Options
  • func GetDefaultOptions() Options
• type Sidecar
  • func NewSidecar(log *zap.Logger, options ...Option) (*Sidecar, error)
  • func (s *Sidecar) Init() error
  • func (s *Sidecar) Run(ctx context.Context) error
  • func (s *Sidecar) RunSession(ctx context.Context, session *web3.Session) error

Constants

const (
	DefaultNatsURL            = "ns://127.0.0.1:4222"
	DefaultNatsQueueName      = "enats"
	DefaultNatsEndpointPrefix = "web3.rpc.request"
	DefaultClientURL          = "ws://127.0.0.1:8545"
	DefaultDataDir            = "./data"
	DefaultRpcHistorySize     = 7200
)

Variables

var (
	DefaultRpcDenyList = []string{"admin_.*"}
)

Types

type Option

type Option func(opts *Options) error

func ClientId

func ClientId(id string) Option

func ClientUrl

func ClientUrl(url string) Option

func DataDir

func DataDir(path string) Option

func NatsEndpointPrefix

func NatsEndpointPrefix(prefix string) Option

func NatsUrl

func NatsUrl(url string) Option

func RpcDenyList

func RpcDenyList(deny []string) Option

func RpcHistorySize

func RpcHistorySize(size int) Option

type Options

type Options struct {
	NatsUrl            string
	NatsQueueName      string
	NatsEndpointPrefix string

	ClientUrl string
	ClientId  string

	DataDir string

	RpcDenyList    []string
	RpcHistorySize int
}

func GetDefaultOptions

func GetDefaultOptions() Options

type Sidecar

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

func NewSidecar

func NewSidecar(log *zap.Logger, options ...Option) (*Sidecar, error)

func (*Sidecar) Init

func (s *Sidecar) Init() error

func (*Sidecar) Run

func (s *Sidecar) Run(ctx context.Context) error

func (*Sidecar) RunSession

func (s *Sidecar) RunSession(ctx context.Context, session *web3.Session) error