dynamic

Documentation

Index

• Constants
• type Client
  • func (d *Client) Read() chan *events.Outbound
  • func (d *Client) Start(bus string)
• type IDynamic
  • func New(opts *opts.DynamicOptions, bus string) (IDynamic, error)

Constants

const (
	// DefaultDynamicAddress is the default address that the dynamic pkg will
	// use if an alternate address is not specified
	DefaultDynamicAddress = "dproxy.batch.sh:443"

	// ReconnectSleep determines the length of time to wait between reconnect attempts to dProxy
	ReconnectSleep = time.Second * 5
)

Types

type Client

type Client struct {
	Client services.DProxyClient
	Conn   *grpc.ClientConn
	Token  string

	MessageBus        string
	OutboundMessageCh chan *events.Outbound

	Options *opts.DynamicOptions
	// contains filtered or unexported fields
}

func (*Client) Read

func (d *Client) Read() chan *events.Outbound

func (*Client) Start

func (d *Client) Start(bus string)

Start is called by a backend's Dynamic() method. It authorizes the connection and begins reading a GRPC stream of responses consisting of DynamicReplay protobuf messages

type IDynamic

type IDynamic interface {
	Start(bus string)
	Read() chan *events.Outbound
}

func New

func New(opts *opts.DynamicOptions, bus string) (IDynamic, error)

New validates CLI options and returns a new Client struct