callbacks

Documentation

Overview

Package callbacks is used to intercept the XDS requests/responses

Index

• type Callbacks
  • func (cb *Callbacks) OnDeltaStreamClosed(id int64, node *corev3.Node)
  • func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, res *discovery.DiscoveryResponse)
  • func (cb *Callbacks) OnStreamClosed(id int64, node *corev3.Node)
  • func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error
  • func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, ...)
  • func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
  • func (cb *Callbacks) OnStreamRequest(id int64, request *discovery.DiscoveryRequest) error
  • func (cb *Callbacks) OnStreamResponse(context context.Context, id int64, request *discovery.DiscoveryRequest, ...)
  • func (cb *Callbacks) Report()

Types

type Callbacks

type Callbacks struct {
}

Callbacks is used to debug the xds server related communication.

func (*Callbacks) OnDeltaStreamClosed

func (cb *Callbacks) OnDeltaStreamClosed(id int64, node *corev3.Node)

OnDeltaStreamClosed is unused.

func (*Callbacks) OnDeltaStreamOpen

func (cb *Callbacks) OnDeltaStreamOpen(_ context.Context, id int64, typ string) error

OnDeltaStreamOpen is unused.

func (*Callbacks) OnFetchRequest

func (cb *Callbacks) OnFetchRequest(_ context.Context, req *discovery.DiscoveryRequest) error

OnFetchRequest prints debug logs

func (*Callbacks) OnFetchResponse

func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, res *discovery.DiscoveryResponse)

OnFetchResponse prints debug logs

func (*Callbacks) OnStreamClosed

func (cb *Callbacks) OnStreamClosed(id int64, node *corev3.Node)

OnStreamClosed prints debug logs

func (*Callbacks) OnStreamDeltaRequest

func (cb *Callbacks) OnStreamDeltaRequest(id int64, req *discovery.DeltaDiscoveryRequest) error

OnStreamDeltaRequest is unused.

func (*Callbacks) OnStreamDeltaResponse

func (cb *Callbacks) OnStreamDeltaResponse(id int64, req *discovery.DeltaDiscoveryRequest, res *discovery.DeltaDiscoveryResponse)

OnStreamDeltaResponse is unused.

func (*Callbacks) OnStreamOpen

func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error

OnStreamOpen prints debug logs

func (*Callbacks) OnStreamRequest

func (cb *Callbacks) OnStreamRequest(id int64, request *discovery.DiscoveryRequest) error

OnStreamRequest prints debug logs

func (*Callbacks) OnStreamResponse

func (cb *Callbacks) OnStreamResponse(context context.Context, id int64, request *discovery.DiscoveryRequest, response *discovery.DiscoveryResponse)

OnStreamResponse prints debug logs

func (*Callbacks) Report

func (cb *Callbacks) Report()

Report logs the fetches and requests.