rpc

Documentation

Index

• type Handler
• type Receive
  • func (srv *Receive) Close()
  • func (srv *Receive) Serve(ctx context.Context, f Handler)
• type Server
  • func New(channel *amqp.Channel, queue string) (Server, error)

Types

type Handler

type Handler func([]byte) ([]byte, error)

Handler defines method for handling of request

type Receive

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

func (*Receive) Close

func (srv *Receive) Close()

Close provides closing and shutdown of the server

func (*Receive) Serve

func (srv *Receive) Serve(ctx context.Context, f Handler)

Serve provides receiving of the messages

type Server

type Server interface {
	Close()
	Serve(context.Context, Handler)
}

Server defines interface for server

func New

func New(channel *amqp.Channel, queue string) (Server, error)

New creates a new receiver