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, ...) *GroupMessageStorer
  • func (s *GroupMessageStorer) StoreLog(ctx context.Context, event types.Log) LogStorageError
• type IdentityUpdateStorer
  • func NewIdentityUpdateStorer(db *sql.DB, logger *zap.Logger, contract *identityupdates.IdentityUpdates, ...) *IdentityUpdateStorer
  • func (s *IdentityUpdateStorer) StoreLog(ctx context.Context, event types.Log) LogStorageError
• type LogStorageError
• type LogStorer

Constants

const (
	// We may not want to hardcode this to 0 and have an originator ID for each smart contract?
	GROUP_MESSAGE_ORIGINATOR_ID = 0
)

const (
	// We may not want to hardcode this to 1 and have an originator ID for each smart contract?
	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 *groupmessages.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 *identityupdates.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