storer

Documentation

Index

• Constants
• func BuildInboxTopic(inboxId [32]byte) string
• func NewLogStorageError(err error, shouldRetry bool) logStorageError
• type GroupMessageStorer
  • func NewGroupMessageStorer(queries *queries.Queries, logger *zap.Logger, contract *abis.GroupMessages) *GroupMessageStorer
  • func (s *GroupMessageStorer) StoreLog(ctx context.Context, event types.Log) LogStorageError
• type IdentityUpdateStorer
  • func NewIdentityUpdateStorer(db *sql.DB, logger *zap.Logger, contract *abis.IdentityUpdates, ...) *IdentityUpdateStorer
  • func (s *IdentityUpdateStorer) StoreLog(ctx context.Context, event types.Log) LogStorageError
• type LogStorageError
• type LogStorer

Constants

const (
	IDENTITY_UPDATE_ORIGINATOR_ID = 1
)

Functions

func BuildInboxTopic

func BuildInboxTopic(inboxId [32]byte) string

func NewLogStorageError

func NewLogStorageError(err error, shouldRetry bool) logStorageError

Types

type GroupMessageStorer

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

func NewGroupMessageStorer

func NewGroupMessageStorer(
	queries *queries.Queries,
	logger *zap.Logger,
	contract *abis.GroupMessages,
) *GroupMessageStorer

func (*GroupMessageStorer) StoreLog

func (s *GroupMessageStorer) StoreLog(ctx context.Context, event types.Log) LogStorageError

Validate and store a group message log event

type IdentityUpdateStorer

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

func NewIdentityUpdateStorer

func NewIdentityUpdateStorer(
	db *sql.DB,
	logger *zap.Logger,
	contract *abis.IdentityUpdates,
	validationService mlsvalidate.MLSValidationService,
) *IdentityUpdateStorer

func (*IdentityUpdateStorer) StoreLog

func (s *IdentityUpdateStorer) StoreLog(ctx context.Context, event types.Log) LogStorageError

Validate and store an identity update log event

type LogStorageError

type LogStorageError interface {
	error
	ShouldRetry() bool
}

type LogStorer

type LogStorer interface {
	StoreLog(ctx context.Context, event types.Log) LogStorageError
}

Takes a log event and stores it, returning either an error that may be retriable, non-retriable, or nil