nats

Documentation

Index

• type Option
  • func BucketProfilesFormat(name string) Option
  • func BucketStatusesFormat(name string) Option
  • func BucketStatusesHistory(history uint8) Option
  • func Create(create bool) Option
  • func NetworkAndChainId(networkId uint64, chainId uint64) Option
• type Options
  • func GetDefaultOptions() Options
• type ProfileStore
• type ResponseStore
• type StateManager
  • func NewStateManager(js nats.JetStreamContext, options ...Option) (*StateManager, error)
• type StatusStore

Types

type Option

type Option = func(opts *Options) error

func BucketProfilesFormat

func BucketProfilesFormat(name string) Option

func BucketStatusesFormat

func BucketStatusesFormat(name string) Option

func BucketStatusesHistory

func BucketStatusesHistory(history uint8) Option

func Create

func Create(create bool) Option

func NetworkAndChainId

func NetworkAndChainId(networkId uint64, chainId uint64) Option

type Options

type Options struct {
	Create bool

	NetworkId uint64
	ChainId   uint64

	BucketConfigStatuses bucketConfigStatuses
	BucketConfigProfiles bucketConfigProfiles
}

func GetDefaultOptions

func GetDefaultOptions() Options

type ProfileStore

type ProfileStore = natsutil.KeyValue[eth.ClientProfile]

type ResponseStore

type ResponseStore = natsutil.KeyValue[jsonrpc.Response]

type StateManager

type StateManager struct {
	Opts      Options
	Status    StatusStore
	Profiles  ProfileStore
	Responses ResponseStore
}

func NewStateManager

func NewStateManager(js nats.JetStreamContext, options ...Option) (*StateManager, error)

type StatusStore

type StatusStore = natsutil.KeyValue[eth.ClientStatus]