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 ¶
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 WithDLQFactory ¶
func WithDLQFactory(params DLQFactoryParams) (DLQ, error)
type DLQFactory ¶
type DLQFactoryParams ¶
type DLQFactoryParams struct { fx.In fxparams.Params SQS DLQFactory `name:"dlq/sqs"` Firestore DLQFactory `name:"dlq/firestore"` }
type FailedBlockData ¶
Click to show internal directories.
Click to hide internal directories.