storage

Jul 4, 2023

Changes in this version

type MemoryStorage

+ func (storage *MemoryStorage) Nack(_ context.Context, msg *message.Message) (modifiedCount int64, err error)

type MongoStorage

+ func (storage *MongoStorage) Nack(ctx context.Context, message *message.Message) (modifiedCount int64, err error)

type Storage

+ Nack func(ctx context.Context, message *message.Message) (modifiedCount int64, err error)

Jun 30, 2023

Changes in this version

+ type FindOptions struct

+ Limit int64

+ Projection *map[string]int

+ Retry bool

+ Sort *orderedmap.OrderedMap[string, int]

+ type InternalFilter struct

+ ExpiryDate *time.Time

+ Ids *[]string

+ InternalIdBreakpointGt string

+ InternalIdBreakpointLte string

+ Queue string

+ QueuePrefix string

+ type MemoryStorage struct

+ func NewMemoryStorage(ctx context.Context) *MemoryStorage

+ func (storage *MemoryStorage) Ack(_ context.Context, message *message.Message) (modifiedCount int64, err error)

+ func (storage *MemoryStorage) Close(ctx context.Context) error

+ func (storage *MemoryStorage) Count(_ context.Context, opts *FindOptions) (int64, error)

+ func (storage *MemoryStorage) EditQueueConfiguration(_ context.Context, configuration *configuration.QueueConfiguration) error

+ func (storage *MemoryStorage) Find(_ context.Context, opt *FindOptions) ([]message.Message, error)

+ func (storage *MemoryStorage) Flush(_ context.Context) (deletedCount int64, err error)

+ func (storage *MemoryStorage) GetQueueConfiguration(_ context.Context, queue string) (*configuration.QueueConfiguration, error)

+ func (storage *MemoryStorage) GetStringInternalId(_ context.Context, message *message.Message) string

+ func (storage *MemoryStorage) Insert(_ context.Context, messages ...*message.Message) (int64, int64, error)

+ func (storage *MemoryStorage) ListQueueConfigurations(ctx context.Context) ([]*configuration.QueueConfiguration, error)

+ func (storage *MemoryStorage) ListQueueNames(_ context.Context) (queues []string, err error)

+ func (storage *MemoryStorage) ListQueuePrefixes(_ context.Context) (queues []string, err error)

+ func (storage *MemoryStorage) Remove(_ context.Context, queue string, ids ...string) (deleted int64, err error)

+ type MongoStorage struct

+ func NewMongoStorage(ctx context.Context) (*MongoStorage, error)

+ func (storage *MongoStorage) Ack(ctx context.Context, message *message.Message) (modifiedCount int64, err error)

+ func (storage *MongoStorage) Close(ctx context.Context) error

+ func (storage *MongoStorage) Count(ctx context.Context, opt *FindOptions) (int64, error)

+ func (storage *MongoStorage) EditQueueConfiguration(ctx context.Context, configuration *configuration.QueueConfiguration) error

+ func (storage *MongoStorage) Find(ctx context.Context, opt *FindOptions) ([]message.Message, error)

+ func (storage *MongoStorage) Flush(ctx context.Context) (int64, error)

+ func (storage *MongoStorage) GetQueueConfiguration(ctx context.Context, queue string) (*configuration.QueueConfiguration, error)

+ func (storage *MongoStorage) GetStringInternalId(_ context.Context, message *message.Message) string

+ func (storage *MongoStorage) Insert(ctx context.Context, messages ...*message.Message) (insertedCount int64, modifiedCount int64, err error)

+ func (storage *MongoStorage) ListQueueConfigurations(ctx context.Context) ([]*configuration.QueueConfiguration, error)

+ func (storage *MongoStorage) ListQueueNames(ctx context.Context) (queues []string, err error)

+ func (storage *MongoStorage) ListQueuePrefixes(ctx context.Context) (queues []string, err error)

+ func (storage *MongoStorage) Remove(ctx context.Context, queue string, ids ...string) (deleted int64, err error)

+ type Storage interface

+ Ack func(ctx context.Context, message *message.Message) (modifiedCount int64, err error)

+ Close func(ctx context.Context) error

+ Count func(ctx context.Context, opt *FindOptions) (int64, error)

+ EditQueueConfiguration func(ctx context.Context, configuration *configuration.QueueConfiguration) error

+ Find func(ctx context.Context, opt *FindOptions) ([]message.Message, error)

+ Flush func(ctx context.Context) (deletedCount int64, err error)

+ GetQueueConfiguration func(ctx context.Context, queue string) (*configuration.QueueConfiguration, error)

+ GetStringInternalId func(ctx context.Context, message *message.Message) string

+ Insert func(ctx context.Context, messages ...*message.Message) (inserted int64, updated int64, err error)

+ ListQueueConfigurations func(ctx context.Context) ([]*configuration.QueueConfiguration, error)

+ ListQueueNames func(ctx context.Context) (queues []string, err error)

+ ListQueuePrefixes func(ctx context.Context) (queues []string, err error)

+ Remove func(ctx context.Context, queue string, ids ...string) (deleted int64, err error)

+ func CreateStorage(ctx context.Context, storageType Type) (Storage, error)

+ type Type string

+ const MEMORY

+ const MONGODB