storage

Documentation

Index

• type DBClient
  • func NewDBClient(l *logrus.Logger, stream string, address string, password string) *DBClient
  • func (db *DBClient) AckMessage(ctx context.Context, groupName string, messageID string) error
  • func (db *DBClient) Consume(ctx context.Context, groupName, consumerName string) (string, *dto.StoredMessage, error)
  • func (db *DBClient) LogMessage(ctx context.Context, message *dto.StoredMessage) error
  • func (db *DBClient) ReadPendingMessages(ctx context.Context, groupName, consumerName string, dur time.Duration) ([]string, []*dto.StoredMessage, error)
  • func (db *DBClient) RegisterConsumer(ctx context.Context, groupName, consumerName string) error

Types

type DBClient

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

func NewDBClient

func NewDBClient(l *logrus.Logger, stream string, address string, password string) *DBClient

func (*DBClient) AckMessage

func (db *DBClient) AckMessage(ctx context.Context, groupName string, messageID string) error

func (*DBClient) Consume

func (db *DBClient) Consume(ctx context.Context, groupName, consumerName string) (string, *dto.StoredMessage, error)

func (*DBClient) LogMessage

func (db *DBClient) LogMessage(ctx context.Context, message *dto.StoredMessage) error

func (*DBClient) ReadPendingMessages

func (db *DBClient) ReadPendingMessages(ctx context.Context, groupName, consumerName string, dur time.Duration) ([]string, []*dto.StoredMessage, error)

func (*DBClient) RegisterConsumer

func (db *DBClient) RegisterConsumer(ctx context.Context, groupName, consumerName string) error