rpc

Documentation

Overview

Package rpc provides functionality for request / reply messaging. It is used by package mgmt and cbs.

Index

• type Link
  • func NewLink(conn *amqp.Client, address string) (*Link, error)
  • func (l *Link) Close() error
  • func (l *Link) RPC(ctx context.Context, msg *amqp.Message) (*Response, error)
  • func (l *Link) RetryableRPC(ctx context.Context, times int, delay time.Duration, msg *amqp.Message) (*Response, error)
• type Response

Types

type Link

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

Link is the bidirectional communication structure used for CBS negotiation

func NewLink

func NewLink(conn *amqp.Client, address string) (*Link, error)

NewLink will build a new request response link

func (*Link) Close

func (l *Link) Close() error

Close the link receiver, sender and session

func (*Link) RPC

func (l *Link) RPC(ctx context.Context, msg *amqp.Message) (*Response, error)

RPC sends a request and waits on a response for that request

func (*Link) RetryableRPC

func (l *Link) RetryableRPC(ctx context.Context, times int, delay time.Duration, msg *amqp.Message) (*Response, error)

RetryableRPC attempts to retry a request a number of times with delay

type Response

type Response struct {
	Code        int
	Description string
	Message     *amqp.Message
}

Response is the simplified response structure from an RPC like call