event

Documentation

Index

• type Event
• type ExampleEvent
  • func (e *ExampleEvent) DelaySeconds() int64
  • func (e *ExampleEvent) Queue() string
  • func (e *ExampleEvent) Unmarshal(value []byte) Event
  • func (e *ExampleEvent) Value() []byte
• type Handler
• type Receiver
• type Sender

Types

type Event

type Event interface {
	Queue() string
	Value() []byte
	DelaySeconds() int64
	Unmarshal(value []byte) Event
}

Event 消息事件

type ExampleEvent

type ExampleEvent struct {
	Desc  string
	Delay int64
}

func (*ExampleEvent) DelaySeconds

func (e *ExampleEvent) DelaySeconds() int64

func (*ExampleEvent) Queue

func (e *ExampleEvent) Queue() string

func (*ExampleEvent) Unmarshal

func (e *ExampleEvent) Unmarshal(value []byte) Event

func (*ExampleEvent) Value

func (e *ExampleEvent) Value() []byte

type Handler

type Handler func(context.Context, Event) error

Handler 消息处理

type Receiver

type Receiver interface {
	Receive(ctx context.Context, msg Event, handler Handler, workerNum int64) error
	Close() error
}

Receiver 消息接收者

type Sender

type Sender interface {
	Send(context.Context, Event) error
	Close() error
}

Sender 消息生产者