internal

package
v0.0.0-...-ae8e89f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source
const (
	FailedBlockTopic            = "failed_block"
	FailedTransactionTraceTopic = "failed_transaction_trace"
)

Variables

View Source
var (
	ErrNotFound = xerrors.New("not found")
)

Functions

func FilterError

func FilterError(err error) bool

Types

type DLQ

type DLQ interface {
	SendMessage(ctx context.Context, message *Message) error
	ResendMessage(ctx context.Context, message *Message) error
	ReceiveMessage(ctx context.Context) (*Message, error)
	DeleteMessage(ctx context.Context, message *Message) error
}

func NewNop

func NewNop() DLQ

func WithDLQFactory

func WithDLQFactory(params DLQFactoryParams) (DLQ, error)

type DLQFactory

type DLQFactory interface {
	Create() (DLQ, error)
}

type DLQFactoryParams

type DLQFactoryParams struct {
	fx.In
	fxparams.Params
	SQS       DLQFactory `name:"dlq/sqs"`
	Firestore DLQFactory `name:"dlq/firestore"`
}

type FailedBlockData

type FailedBlockData struct {
	Tag    uint32
	Height uint64
}

type FailedTransactionTraceData

type FailedTransactionTraceData struct {
	Tag                 uint32
	Height              uint64
	Hash                string
	IgnoredTransactions []int
}

type Message

type Message struct {
	Topic         string
	Retries       int
	SentTimestamp time.Time
	ReceiptHandle string
	Data          any
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL