Documentation
¶
Overview ¶
Code generated by create_version. DO NOT EDIT.
Index ¶
- type Callbacks
- func (cb *Callbacks) OnDeltaStreamClosed(int64)
- func (cb *Callbacks) OnDeltaStreamOpen(context.Context, int64, string) error
- func (cb *Callbacks) OnFetchRequest(ctx context.Context, req *discovery.DiscoveryRequest) error
- func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)
- func (cb *Callbacks) OnStreamClosed(id int64)
- func (cb *Callbacks) OnStreamDeltaRequest(int64, *discovery.DeltaDiscoveryRequest) error
- func (cb *Callbacks) OnStreamDeltaResponse(int64, *discovery.DeltaDiscoveryRequest, *discovery.DeltaDiscoveryResponse)
- func (cb *Callbacks) OnStreamOpen(_ context.Context, id int64, typ string) error
- func (cb *Callbacks) OnStreamRequest(a int64, d *discovery.DiscoveryRequest) error
- func (cb *Callbacks) OnStreamResponse(c context.Context, a int64, req *discovery.DiscoveryRequest, ...)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Callbacks ¶
type Callbacks struct {
//Stream counters
ActiveStrms *prometheus.Gauge
ReqC *prometheus.Counter
ResC *prometheus.Counter
// contains filtered or unexported fields
}
func (*Callbacks) OnDeltaStreamClosed ¶ added in v0.2.0
OnDeltaStreamClosed is called immediately prior to closing an xDS stream with a stream ID.
func (*Callbacks) OnDeltaStreamOpen ¶ added in v0.2.0
OnDeltaStreamOpen is called once an incremental xDS stream is open with a stream ID and the type URL (or "" for ADS). Returning an error will end processing and close the stream. OnStreamClosed will still be called.
func (*Callbacks) OnFetchRequest ¶
OnFetchRequest Marker Impl: No expecting Rest Client
func (*Callbacks) OnFetchResponse ¶
func (cb *Callbacks) OnFetchResponse(req *discovery.DiscoveryRequest, resp *discovery.DiscoveryResponse)
OnFetchResponse Marker Impl: No expecting Rest Client
func (*Callbacks) OnStreamClosed ¶
OnStreamClosed is called immediately prior to closing an xDS stream with a stream ID.
func (*Callbacks) OnStreamDeltaRequest ¶ added in v0.2.0
func (cb *Callbacks) OnStreamDeltaRequest(int64, *discovery.DeltaDiscoveryRequest) error
OnStreamDeltaRequest is called once a request is received on a stream. Returning an error will end processing and close the stream. OnStreamClosed will still be called.
func (*Callbacks) OnStreamDeltaResponse ¶ added in v0.2.0
func (cb *Callbacks) OnStreamDeltaResponse(int64, *discovery.DeltaDiscoveryRequest, *discovery.DeltaDiscoveryResponse)
OnStreamDelatResponse is called immediately prior to sending a response on a stream.
func (*Callbacks) OnStreamOpen ¶
OnStreamOpen is called once an xDS stream is open with a stream ID and the type URL (or "" for ADS). Returning an error will end processing and close the stream. OnStreamClosed will still be called.
func (*Callbacks) OnStreamRequest ¶
func (cb *Callbacks) OnStreamRequest(a int64, d *discovery.DiscoveryRequest) error
OnStreamRequest is called once a request is received on a stream. Returning an error will end processing and close the stream. OnStreamClosed will still be called.
func (*Callbacks) OnStreamResponse ¶
func (cb *Callbacks) OnStreamResponse(c context.Context, a int64, req *discovery.DiscoveryRequest, d *discovery.DiscoveryResponse)
OnStreamResponse is called immediately prior to sending a response on a stream.
Source Files