delayq

Documentation

Index

• type Action
• type Message
  • func (m *Message) Decode(data []byte) error
  • func (m *Message) Encode() ([]byte, error)
  • func (m *Message) Extract(ctx context.Context) (context.Context, trace.Span)
  • func (m *Message) Inject(ctx context.Context) (context.Context, trace.Span)

Types

type Action

type Action string

type Message

type Message struct {
	Carrier propagation.MapCarrier
	Action  Action
	Body    []byte
}

func (*Message) Decode

func (m *Message) Decode(data []byte) error

func (*Message) Encode

func (m *Message) Encode() ([]byte, error)

func (*Message) Extract

func (m *Message) Extract(ctx context.Context) (context.Context, trace.Span)

func (*Message) Inject

func (m *Message) Inject(ctx context.Context) (context.Context, trace.Span)