rpc

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 (srv *Receive) Close()

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

type Server ¶

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

Server defines interface for server

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