Documentation ¶
Index ¶
- type ExplorerClient
- func (_m *ExplorerClient) Close() error
- func (_m *ExplorerClient) Healthy() error
- func (_m *ExplorerClient) Ready() error
- func (_m *ExplorerClient) Receive(_a0 context.Context, _a1 ...time.Duration) ([]byte, error)
- func (_m *ExplorerClient) Send(_a0 context.Context, _a1 []byte, _a2 ...int)
- func (_m *ExplorerClient) Start(_a0 context.Context) error
- func (_m *ExplorerClient) Status() synchronization.ConnectionStatus
- func (_m *ExplorerClient) Url() url.URL
- type TelemClient
- type TelemetryIngressBatchClient
- func (_m *TelemetryIngressBatchClient) Close() error
- func (_m *TelemetryIngressBatchClient) Healthy() error
- func (_m *TelemetryIngressBatchClient) Ready() error
- func (_m *TelemetryIngressBatchClient) Send(_a0 synchronization.TelemPayload)
- func (_m *TelemetryIngressBatchClient) Start(_a0 context.Context) error
- type TelemetryIngressClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExplorerClient ¶ added in v1.13.0
ExplorerClient is an autogenerated mock type for the ExplorerClient type
func NewExplorerClient ¶ added in v1.13.0
func NewExplorerClient(t mockConstructorTestingTNewExplorerClient) *ExplorerClient
NewExplorerClient creates a new instance of ExplorerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*ExplorerClient) Close ¶ added in v1.13.0
func (_m *ExplorerClient) Close() error
Close provides a mock function with given fields:
func (*ExplorerClient) Healthy ¶ added in v1.13.0
func (_m *ExplorerClient) Healthy() error
Healthy provides a mock function with given fields:
func (*ExplorerClient) Ready ¶ added in v1.13.0
func (_m *ExplorerClient) Ready() error
Ready provides a mock function with given fields:
func (*ExplorerClient) Receive ¶ added in v1.13.0
Receive provides a mock function with given fields: _a0, _a1
func (*ExplorerClient) Send ¶ added in v1.13.0
func (_m *ExplorerClient) Send(_a0 context.Context, _a1 []byte, _a2 ...int)
Send provides a mock function with given fields: _a0, _a1, _a2
func (*ExplorerClient) Start ¶ added in v1.13.0
func (_m *ExplorerClient) Start(_a0 context.Context) error
Start provides a mock function with given fields: _a0
func (*ExplorerClient) Status ¶ added in v1.13.0
func (_m *ExplorerClient) Status() synchronization.ConnectionStatus
Status provides a mock function with given fields:
func (*ExplorerClient) Url ¶ added in v1.13.0
func (_m *ExplorerClient) Url() url.URL
Url provides a mock function with given fields:
type TelemClient ¶
TelemClient is an autogenerated mock type for the TelemClient type
func NewTelemClient ¶ added in v1.5.0
func NewTelemClient(t mockConstructorTestingTNewTelemClient) *TelemClient
NewTelemClient creates a new instance of TelemClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TelemClient) Telem ¶
func (_m *TelemClient) Telem(ctx context.Context, in *telem.TelemRequest) (*telem.TelemResponse, error)
Telem provides a mock function with given fields: ctx, in
func (*TelemClient) TelemBatch ¶ added in v1.2.0
func (_m *TelemClient) TelemBatch(ctx context.Context, in *telem.TelemBatchRequest) (*telem.TelemResponse, error)
TelemBatch provides a mock function with given fields: ctx, in
type TelemetryIngressBatchClient ¶ added in v1.13.0
TelemetryIngressBatchClient is an autogenerated mock type for the TelemetryIngressBatchClient type
func NewTelemetryIngressBatchClient ¶ added in v1.13.0
func NewTelemetryIngressBatchClient(t mockConstructorTestingTNewTelemetryIngressBatchClient) *TelemetryIngressBatchClient
NewTelemetryIngressBatchClient creates a new instance of TelemetryIngressBatchClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TelemetryIngressBatchClient) Close ¶ added in v1.13.0
func (_m *TelemetryIngressBatchClient) Close() error
Close provides a mock function with given fields:
func (*TelemetryIngressBatchClient) Healthy ¶ added in v1.13.0
func (_m *TelemetryIngressBatchClient) Healthy() error
Healthy provides a mock function with given fields:
func (*TelemetryIngressBatchClient) Ready ¶ added in v1.13.0
func (_m *TelemetryIngressBatchClient) Ready() error
Ready provides a mock function with given fields:
func (*TelemetryIngressBatchClient) Send ¶ added in v1.13.0
func (_m *TelemetryIngressBatchClient) Send(_a0 synchronization.TelemPayload)
Send provides a mock function with given fields: _a0
type TelemetryIngressClient ¶ added in v1.13.0
TelemetryIngressClient is an autogenerated mock type for the TelemetryIngressClient type
func NewTelemetryIngressClient ¶ added in v1.13.0
func NewTelemetryIngressClient(t mockConstructorTestingTNewTelemetryIngressClient) *TelemetryIngressClient
NewTelemetryIngressClient creates a new instance of TelemetryIngressClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*TelemetryIngressClient) Close ¶ added in v1.13.0
func (_m *TelemetryIngressClient) Close() error
Close provides a mock function with given fields:
func (*TelemetryIngressClient) Healthy ¶ added in v1.13.0
func (_m *TelemetryIngressClient) Healthy() error
Healthy provides a mock function with given fields:
func (*TelemetryIngressClient) Ready ¶ added in v1.13.0
func (_m *TelemetryIngressClient) Ready() error
Ready provides a mock function with given fields:
func (*TelemetryIngressClient) Send ¶ added in v1.13.0
func (_m *TelemetryIngressClient) Send(_a0 synchronization.TelemPayload)
Send provides a mock function with given fields: _a0