job

Documentation

Index

• func NewMessage(key string, value []byte, header map[string]string) event2.Message
• type Message
  • func (m *Message) Header() map[string]string
  • func (m *Message) Key() string
  • func (m *Message) Value() []byte
• type Server
  • func NewJOBServer(c *conf.Server, uo *service.OrderService) *Server
  • func (s Server) Close() error
  • func (s Server) Receive(ctx context.Context, handler event2.Handler) error
  • func (s Server) Start(ctx context.Context) error
  • func (s Server) Stop(ctx context.Context) error
• type Transport
  • func (t Transport) Endpoint() string
  • func (t Transport) Kind() transport.Kind
  • func (t Transport) Operation() string
  • func (t Transport) ReplyHeader() transport.Header
  • func (t Transport) RequestHeader() transport.Header

Functions

func NewMessage

func NewMessage(key string, value []byte, header map[string]string) event2.Message

Types

type Message

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

func (*Message) Header

func (m *Message) Header() map[string]string

func (*Message) Key

func (m *Message) Key() string

func (*Message) Value

func (m *Message) Value() []byte

type Server

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

func NewJOBServer

func NewJOBServer(c *conf.Server, uo *service.OrderService) *Server

func (Server) Close

func (s Server) Close() error

func (Server) Receive

func (s Server) Receive(ctx context.Context, handler event2.Handler) error

func (Server) Start

func (s Server) Start(ctx context.Context) error

func (Server) Stop

func (s Server) Stop(ctx context.Context) error

type Transport

type Transport struct {
}

func (Transport) Endpoint

func (t Transport) Endpoint() string

func (Transport) Kind

func (t Transport) Kind() transport.Kind

func (Transport) Operation

func (t Transport) Operation() string

func (Transport) ReplyHeader

func (t Transport) ReplyHeader() transport.Header

func (Transport) RequestHeader

func (t Transport) RequestHeader() transport.Header