nats

Documentation

Index

• Constants
• Variables
• type ApplyStoreOptionFunc
• type Store
  • func New(nc *nats.Conn, enc codec.Encoding, opts ...StoreOption) (*Store, error)
  • func (s *Store) Delete(_ context.Context, _ ...event.Event) error
  • func (s *Store) Find(_ context.Context, _ uuid.UUID) (event.Event, error)
  • func (s *Store) Insert(ctx context.Context, evts ...event.Event) error
  • func (s *Store) Query(ctx context.Context, q event.Query) (<-chan event.Event, <-chan error, error)
• type StoreOption
  • func WithLogger(o *zap.SugaredLogger) StoreOption
  • func WithPullExpiry(o time.Duration) StoreOption
  • func WithRetryCount(o uint) StoreOption
  • func WithVersionKV(o kv.KeyValuer[*kv.UInt64Value]) StoreOption
  • func WithWriteLeaseKV(o kv.KeyValuer[*kv.NilValue]) StoreOption

Constants

const (
	MetadataKeyEventName             = "event-name"
	MetadataKeyEventTime             = "event-time"
	MetadataKeyEventAggregateName    = "aggregate-name"
	MetadataKeyEventAggregateId      = "aggregate-id"
	MetadataKeyEventAggregateVersion = "aggregate-version"
)

Event metadata keys

Variables

var (
	ErrLeaseLocked               = errors.New("lease is currently locked")
	ErrValidationVersionMismatch = errors.New("validation version mismatch")
)

Error

Types

type ApplyStoreOptionFunc

type ApplyStoreOptionFunc func(c *Store) error

type Store

type Store struct {
	// contains filtered or unexported fields
}

func New

func New(nc *nats.Conn, enc codec.Encoding, opts ...StoreOption) (*Store, error)

func (*Store) Delete

func (s *Store) Delete(_ context.Context, _ ...event.Event) error

Delete deletes events from the store.

func (*Store) Find

func (s *Store) Find(_ context.Context, _ uuid.UUID) (event.Event, error)

Find fetches the given event from the store.

func (*Store) Insert

func (s *Store) Insert(ctx context.Context, evts ...event.Event) error

Insert inserts events into the store.

func (*Store) Query

func (s *Store) Query(ctx context.Context, q event.Query) (<-chan event.Event, <-chan error, error)

Query queries the store for events and returns two channels – one for the returned events and one for any asynchronous errors that occur during the query.

type StoreOption

type StoreOption interface {
	// contains filtered or unexported methods
}

func WithLogger

func WithLogger(o *zap.SugaredLogger) StoreOption

func WithPullExpiry

func WithPullExpiry(o time.Duration) StoreOption

func WithRetryCount

func WithRetryCount(o uint) StoreOption

func WithVersionKV

func WithVersionKV(o kv.KeyValuer[*kv.UInt64Value]) StoreOption

func WithWriteLeaseKV

func WithWriteLeaseKV(o kv.KeyValuer[*kv.NilValue]) StoreOption