queue

Documentation

Index

• Constants
• type Message
• type Queue
  • func New() Queue

Constants

const CName = "push.queue"

Types

type Message

type Message struct {
	IgnoreAccountId string `json:"ignoreAccountId"`
	KeyId           string
	Payload         []byte
	Signature       []byte
	Topics          []domain.Topic `json:"topics"`
}

type Queue

type Queue interface {
	Add(ctx context.Context, msg Message) error
	Consume(ctx context.Context, handle func(msg Message) error) error
	app.ComponentRunnable
}

func New

func New() Queue