nats

type CacheEntry struct{}

type KeyValue[T any] interface {
	Delegate() nats.KeyValue

	Bucket() string

	Get(key string) (KeyValueEntry[T], error)

	Put(key string, value T) (uint64, error)

	Watch(key string, opts ...nats.WatchOpt) (KeyWatcher[T], error)

	WatchAll(opts ...nats.WatchOpt) (KeyWatcher[T], error)

	Delete(key string) error
}

type KeyValueEntry[T any] interface {
	// Bucket is the bucket the data was loaded from.
	Bucket() string
	// Key is the key that was retrieved.
	Key() string
	// Value is the retrieved value unmarshalled from json.
	Value() (T, error)
	// ValueRaw is the original []byte value.
	ValueRaw() []byte
	// Revision is a unique sequence for this value.
	Revision() uint64
	// Created is the time the data was put in the bucket.
	Created() time.Time
	// Delta is distance from the latest value.
	Delta() uint64
	// Operation returns Put or Delete or Purge.
	Operation() nats.KeyValueOp
}

type KeyWatcher[T any] interface {
	// Context returns watcher context optionally provided by nats.Context option.
	Context() context.Context
	// Updates returns a channel to read any updates to entries.
	Updates() <-chan KeyValueEntry[T]
	// Stop will stop this watcher.
	Stop() error
}

type Publisher[T any] struct {
	Subject string
	// contains filtered or unexported fields
}

type RouteOpt = func(opts *RouteOpts) error

type RouteOpts struct {
	Cache bool
}

type Router interface {
	Request(req jsonrpc.Request, resp *jsonrpc.Response, timeout time.Duration, options ...RouteOpt) error

	RequestWithContext(ctx context.Context, req jsonrpc.Request, resp *jsonrpc.Response, options ...RouteOpt) error
}

type RpcServer struct {
	Options RpcServerOptions
	// contains filtered or unexported fields
}

type RpcServerOption func(*RpcServerOptions) error

type RpcServerOptions struct {
	// ClientId is the unique node id (public key) for the web3 client
	ClientId string

	// NetworkId is the ethereum network id that the web3 client is connected to.
	NetworkId uint64

	// ChainId is the ethereum chain id that the web3 client is connect to.
	ChainId uint64

	// MaxInFlightRequests constrains the max number of rpc requests that can be
	// awaiting a response from the web3 client.
	MaxInFlightRequests int
}