mvplive

Documentation

Index

• type Channel
  • func (ch Channel) String() string
• type ChannelFamily
• type Envelope
• type Msg
• type Queue
  • func NewQueue(opt QueueOptions) *Queue
  • func (q *Queue) Await(ctx context.Context, ch Channel, afterID flake.ID) []*Msg
  • func (q *Queue) MessagesAfter(ch Channel, afterID flake.ID, now time.Time) []*Msg
  • func (q *Queue) Push(ch Channel, msg *Msg)
• type QueueOptions

Types

type Channel

type Channel struct {
	Family *ChannelFamily
	Topic  string
}

func (Channel) String

func (ch Channel) String() string

type ChannelFamily

type ChannelFamily struct {
	Name string
}

type Envelope

type Envelope struct {
	EventID  uint64
	DedupKey string
}

type Msg

type Msg struct {
	ID flake.ID
	Envelope
	Data []byte
}

type Queue

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

func NewQueue

func NewQueue(opt QueueOptions) *Queue

func (*Queue) Await

func (q *Queue) Await(ctx context.Context, ch Channel, afterID flake.ID) []*Msg

func (*Queue) MessagesAfter

func (q *Queue) MessagesAfter(ch Channel, afterID flake.ID, now time.Time) []*Msg

func (*Queue) Push

func (q *Queue) Push(ch Channel, msg *Msg)

type QueueOptions

type QueueOptions struct {
	TTL                   time.Duration
	MaxMessagesPerChannel int
}