msg

Documentation

Index

• func CreateTables(ctx context.Context, chDB *ch.DB, pgDB *bun.DB) error
• type Repository
  • func NewRepository(ck *ch.DB, pg *bun.DB) *Repository
  • func (r *Repository) AddMessages(ctx context.Context, tx bun.Tx, messages []*core.Message) error
  • func (r *Repository) AggregateMessages(ctx context.Context, req *aggregate.MessagesReq) (*aggregate.MessagesRes, error)
  • func (r *Repository) AggregateMessagesHistory(ctx context.Context, req *history.MessagesReq) (*history.MessagesRes, error)
  • func (r *Repository) FilterMessages(ctx context.Context, req *filter.MessagesReq) (*filter.MessagesRes, error)
  • func (r *Repository) GetMessage(ctx context.Context, hash []byte) (*core.Message, error)
  • func (r *Repository) GetMessages(ctx context.Context, hashes [][]byte) ([]*core.Message, error)
  • func (r *Repository) MatchMessagesByOperationDesc(ctx context.Context, contractName abi.ContractName, msgType core.MessageType, ...) ([][]byte, error)
  • func (r *Repository) UpdateMessages(ctx context.Context, messages []*core.Message) error

Functions

func CreateTables

func CreateTables(ctx context.Context, chDB *ch.DB, pgDB *bun.DB) error

Types

type Repository

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

func NewRepository

func NewRepository(ck *ch.DB, pg *bun.DB) *Repository

func (*Repository) AddMessages

func (r *Repository) AddMessages(ctx context.Context, tx bun.Tx, messages []*core.Message) error

func (*Repository) AggregateMessages

func (r *Repository) AggregateMessages(ctx context.Context, req *aggregate.MessagesReq) (*aggregate.MessagesRes, error)

func (*Repository) AggregateMessagesHistory

func (r *Repository) AggregateMessagesHistory(ctx context.Context, req *history.MessagesReq) (*history.MessagesRes, error)

func (*Repository) FilterMessages

func (r *Repository) FilterMessages(ctx context.Context, req *filter.MessagesReq) (*filter.MessagesRes, error)

func (*Repository) GetMessage

func (r *Repository) GetMessage(ctx context.Context, hash []byte) (*core.Message, error)

func (*Repository) GetMessages

func (r *Repository) GetMessages(ctx context.Context, hashes [][]byte) ([]*core.Message, error)

func (*Repository) MatchMessagesByOperationDesc

func (r *Repository) MatchMessagesByOperationDesc(ctx context.Context,
	contractName abi.ContractName,
	msgType core.MessageType,
	outgoing bool,
	operationId uint32,
	afterAddress *addr.Address,
	afterTxLt uint64,
	limit int,
) ([][]byte, error)

MatchMessagesByOperationDesc returns hashes of suitable messages for the given contract operation.

func (*Repository) UpdateMessages

func (r *Repository) UpdateMessages(ctx context.Context, messages []*core.Message) error