mocks

Documentation

Index

• type ExplorerClient
  • func NewExplorerClient(t mockConstructorTestingTNewExplorerClient) *ExplorerClient
  • func (_m *ExplorerClient) Close() error
  • func (_m *ExplorerClient) HealthReport() map[string]error
  • func (_m *ExplorerClient) Name() string
  • 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
  • func NewTelemClient(t mockConstructorTestingTNewTelemClient) *TelemClient
  • func (_m *TelemClient) Telem(ctx context.Context, in *telem.TelemRequest) (*telem.TelemResponse, error)
  • func (_m *TelemClient) TelemBatch(ctx context.Context, in *telem.TelemBatchRequest) (*telem.TelemResponse, error)
• type TelemetryIngressBatchClient
  • func NewTelemetryIngressBatchClient(t mockConstructorTestingTNewTelemetryIngressBatchClient) *TelemetryIngressBatchClient
  • func (_m *TelemetryIngressBatchClient) Close() error
  • func (_m *TelemetryIngressBatchClient) HealthReport() map[string]error
  • func (_m *TelemetryIngressBatchClient) Name() string
  • func (_m *TelemetryIngressBatchClient) Ready() error
  • func (_m *TelemetryIngressBatchClient) Send(_a0 synchronization.TelemPayload)
  • func (_m *TelemetryIngressBatchClient) Start(_a0 context.Context) error
• type TelemetryIngressClient
  • func NewTelemetryIngressClient(t mockConstructorTestingTNewTelemetryIngressClient) *TelemetryIngressClient
  • func (_m *TelemetryIngressClient) Close() error
  • func (_m *TelemetryIngressClient) HealthReport() map[string]error
  • func (_m *TelemetryIngressClient) Name() string
  • func (_m *TelemetryIngressClient) Ready() error
  • func (_m *TelemetryIngressClient) Send(_a0 synchronization.TelemPayload)
  • func (_m *TelemetryIngressClient) Start(_a0 context.Context) error

Types

type ExplorerClient

type ExplorerClient struct {
	mock.Mock
}

ExplorerClient is an autogenerated mock type for the ExplorerClient type

func NewExplorerClient

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

func (_m *ExplorerClient) Close() error

Close provides a mock function with given fields:

func (*ExplorerClient) HealthReport

func (_m *ExplorerClient) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*ExplorerClient) Name

func (_m *ExplorerClient) Name() string

Name provides a mock function with given fields:

func (*ExplorerClient) Ready

func (_m *ExplorerClient) Ready() error

Ready provides a mock function with given fields:

func (*ExplorerClient) Receive

func (_m *ExplorerClient) Receive(_a0 context.Context, _a1 ...time.Duration) ([]byte, error)

Receive provides a mock function with given fields: _a0, _a1

func (*ExplorerClient) Send

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

func (_m *ExplorerClient) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

func (*ExplorerClient) Status

func (_m *ExplorerClient) Status() synchronization.ConnectionStatus

Status provides a mock function with given fields:

func (*ExplorerClient) Url

func (_m *ExplorerClient) Url() url.URL

Url provides a mock function with given fields:

type TelemClient

type TelemClient struct {
	mock.Mock
}

TelemClient is an autogenerated mock type for the TelemClient type

func NewTelemClient

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

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

type TelemetryIngressBatchClient struct {
	mock.Mock
}

TelemetryIngressBatchClient is an autogenerated mock type for the TelemetryIngressBatchClient type

func NewTelemetryIngressBatchClient

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

func (_m *TelemetryIngressBatchClient) Close() error

Close provides a mock function with given fields:

func (*TelemetryIngressBatchClient) HealthReport

func (_m *TelemetryIngressBatchClient) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*TelemetryIngressBatchClient) Name

func (_m *TelemetryIngressBatchClient) Name() string

Name provides a mock function with given fields:

func (*TelemetryIngressBatchClient) Ready

func (_m *TelemetryIngressBatchClient) Ready() error

Ready provides a mock function with given fields:

func (*TelemetryIngressBatchClient) Send

func (_m *TelemetryIngressBatchClient) Send(_a0 synchronization.TelemPayload)

Send provides a mock function with given fields: _a0

func (*TelemetryIngressBatchClient) Start

func (_m *TelemetryIngressBatchClient) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0

type TelemetryIngressClient

type TelemetryIngressClient struct {
	mock.Mock
}

TelemetryIngressClient is an autogenerated mock type for the TelemetryIngressClient type

func NewTelemetryIngressClient

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

func (_m *TelemetryIngressClient) Close() error

Close provides a mock function with given fields:

func (*TelemetryIngressClient) HealthReport

func (_m *TelemetryIngressClient) HealthReport() map[string]error

HealthReport provides a mock function with given fields:

func (*TelemetryIngressClient) Name

func (_m *TelemetryIngressClient) Name() string

Name provides a mock function with given fields:

func (*TelemetryIngressClient) Ready

func (_m *TelemetryIngressClient) Ready() error

Ready provides a mock function with given fields:

func (*TelemetryIngressClient) Send

func (_m *TelemetryIngressClient) Send(_a0 synchronization.TelemPayload)

Send provides a mock function with given fields: _a0

func (*TelemetryIngressClient) Start

func (_m *TelemetryIngressClient) Start(_a0 context.Context) error

Start provides a mock function with given fields: _a0