model

package
v0.0.0-...-1b30ddd Latest Latest
Warning

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

Go to latest
Published: Sep 8, 2024 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Message

type Message struct {
	Id           string
	Payload      json.RawMessage
	ConsumeCount int
	CreatedAt    time.Time
}

type MessageHandle

type MessageHandle interface {
	MessageHandler(Message) error
}

type QueueStorage

type QueueStorage interface {
	CreateChannel(string) error
	CreateDeadLetterQueue(string) error
	SaveDeadLetterQueue(queueName string, msg Message, errMsg string) error
	Save(string, []byte, string) error
	Read(int, int64, string, string) ([]Message, error)
	Close() error
}

Jump to

Keyboard shortcuts

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