mocks

Documentation

Index

• type PeerDataNodeClient
  • func (_m *PeerDataNodeClient) BenchmarkFileTransfer(ctx context.Context, in *rpc.BenchmarkRequest, opts ...grpc.CallOption) (rpc.PeerDataNode_BenchmarkFileTransferClient, error)
  • func (_m *PeerDataNodeClient) FetchTableShardMetaData(ctx context.Context, in *rpc.TableShardMetaDataRequest, ...) (*rpc.TableShardMetaData, error)
  • func (_m *PeerDataNodeClient) FetchVectorPartyRawData(ctx context.Context, in *rpc.VectorPartyRawDataRequest, ...) (rpc.PeerDataNode_FetchVectorPartyRawDataClient, error)
  • func (_m *PeerDataNodeClient) Health(ctx context.Context, in *rpc.HealthCheckRequest, opts ...grpc.CallOption) (*rpc.HealthCheckResponse, error)
  • func (_m *PeerDataNodeClient) KeepAlive(ctx context.Context, opts ...grpc.CallOption) (rpc.PeerDataNode_KeepAliveClient, error)
  • func (_m *PeerDataNodeClient) StartSession(ctx context.Context, in *rpc.StartSessionRequest, opts ...grpc.CallOption) (*rpc.Session, error)
• type PeerDataNode_BenchmarkFileTransferClient
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) CloseSend() error
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) Context() context.Context
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) Header() (metadata.MD, error)
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) Recv() (*rpc.VectorPartyRawData, error)
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) RecvMsg(m interface{}) error
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) SendMsg(m interface{}) error
  • func (_m *PeerDataNode_BenchmarkFileTransferClient) Trailer() metadata.MD
• type PeerDataNode_FetchVectorPartyRawDataClient
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) CloseSend() error
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Context() context.Context
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Header() (metadata.MD, error)
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Recv() (*rpc.VectorPartyRawData, error)
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) RecvMsg(m interface{}) error
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) SendMsg(m interface{}) error
  • func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Trailer() metadata.MD
• type PeerDataNode_KeepAliveClient
  • func (_m *PeerDataNode_KeepAliveClient) CloseSend() error
  • func (_m *PeerDataNode_KeepAliveClient) Context() context.Context
  • func (_m *PeerDataNode_KeepAliveClient) Header() (metadata.MD, error)
  • func (_m *PeerDataNode_KeepAliveClient) Recv() (*rpc.KeepAliveResponse, error)
  • func (_m *PeerDataNode_KeepAliveClient) RecvMsg(m interface{}) error
  • func (_m *PeerDataNode_KeepAliveClient) Send(_a0 *rpc.Session) error
  • func (_m *PeerDataNode_KeepAliveClient) SendMsg(m interface{}) error
  • func (_m *PeerDataNode_KeepAliveClient) Trailer() metadata.MD

Types

type PeerDataNodeClient

type PeerDataNodeClient struct {
	mock.Mock
}

PeerDataNodeClient is an autogenerated mock type for the PeerDataNodeClient type

func (*PeerDataNodeClient) BenchmarkFileTransfer

func (_m *PeerDataNodeClient) BenchmarkFileTransfer(ctx context.Context, in *rpc.BenchmarkRequest, opts ...grpc.CallOption) (rpc.PeerDataNode_BenchmarkFileTransferClient, error)

BenchmarkFileTransfer provides a mock function with given fields: ctx, in, opts

func (*PeerDataNodeClient) FetchTableShardMetaData

func (_m *PeerDataNodeClient) FetchTableShardMetaData(ctx context.Context, in *rpc.TableShardMetaDataRequest, opts ...grpc.CallOption) (*rpc.TableShardMetaData, error)

FetchTableShardMetaData provides a mock function with given fields: ctx, in, opts

func (*PeerDataNodeClient) FetchVectorPartyRawData

func (_m *PeerDataNodeClient) FetchVectorPartyRawData(ctx context.Context, in *rpc.VectorPartyRawDataRequest, opts ...grpc.CallOption) (rpc.PeerDataNode_FetchVectorPartyRawDataClient, error)

FetchVectorPartyRawData provides a mock function with given fields: ctx, in, opts

func (*PeerDataNodeClient) Health

func (_m *PeerDataNodeClient) Health(ctx context.Context, in *rpc.HealthCheckRequest, opts ...grpc.CallOption) (*rpc.HealthCheckResponse, error)

Health provides a mock function with given fields: ctx, in, opts

func (*PeerDataNodeClient) KeepAlive

func (_m *PeerDataNodeClient) KeepAlive(ctx context.Context, opts ...grpc.CallOption) (rpc.PeerDataNode_KeepAliveClient, error)

KeepAlive provides a mock function with given fields: ctx, opts

func (*PeerDataNodeClient) StartSession

func (_m *PeerDataNodeClient) StartSession(ctx context.Context, in *rpc.StartSessionRequest, opts ...grpc.CallOption) (*rpc.Session, error)

StartSession provides a mock function with given fields: ctx, in, opts

type PeerDataNode_BenchmarkFileTransferClient

type PeerDataNode_BenchmarkFileTransferClient struct {
	mock.Mock
}

PeerDataNode_BenchmarkFileTransferClient is an autogenerated mock type for the PeerDataNode_BenchmarkFileTransferClient type

func (*PeerDataNode_BenchmarkFileTransferClient) CloseSend

func (_m *PeerDataNode_BenchmarkFileTransferClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*PeerDataNode_BenchmarkFileTransferClient) Context

func (_m *PeerDataNode_BenchmarkFileTransferClient) Context() context.Context

Context provides a mock function with given fields:

func (*PeerDataNode_BenchmarkFileTransferClient) Header

func (_m *PeerDataNode_BenchmarkFileTransferClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*PeerDataNode_BenchmarkFileTransferClient) Recv

func (_m *PeerDataNode_BenchmarkFileTransferClient) Recv() (*rpc.VectorPartyRawData, error)

Recv provides a mock function with given fields:

func (*PeerDataNode_BenchmarkFileTransferClient) RecvMsg

func (_m *PeerDataNode_BenchmarkFileTransferClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*PeerDataNode_BenchmarkFileTransferClient) SendMsg

func (_m *PeerDataNode_BenchmarkFileTransferClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*PeerDataNode_BenchmarkFileTransferClient) Trailer

func (_m *PeerDataNode_BenchmarkFileTransferClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type PeerDataNode_FetchVectorPartyRawDataClient

type PeerDataNode_FetchVectorPartyRawDataClient struct {
	mock.Mock
}

PeerDataNode_FetchVectorPartyRawDataClient is an autogenerated mock type for the PeerDataNode_FetchVectorPartyRawDataClient type

func (*PeerDataNode_FetchVectorPartyRawDataClient) CloseSend

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*PeerDataNode_FetchVectorPartyRawDataClient) Context

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Context() context.Context

Context provides a mock function with given fields:

func (*PeerDataNode_FetchVectorPartyRawDataClient) Header

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*PeerDataNode_FetchVectorPartyRawDataClient) Recv

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Recv() (*rpc.VectorPartyRawData, error)

Recv provides a mock function with given fields:

func (*PeerDataNode_FetchVectorPartyRawDataClient) RecvMsg

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*PeerDataNode_FetchVectorPartyRawDataClient) SendMsg

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*PeerDataNode_FetchVectorPartyRawDataClient) Trailer

func (_m *PeerDataNode_FetchVectorPartyRawDataClient) Trailer() metadata.MD

Trailer provides a mock function with given fields:

type PeerDataNode_KeepAliveClient

type PeerDataNode_KeepAliveClient struct {
	mock.Mock
}

PeerDataNode_KeepAliveClient is an autogenerated mock type for the PeerDataNode_KeepAliveClient type

func (*PeerDataNode_KeepAliveClient) CloseSend

func (_m *PeerDataNode_KeepAliveClient) CloseSend() error

CloseSend provides a mock function with given fields:

func (*PeerDataNode_KeepAliveClient) Context

func (_m *PeerDataNode_KeepAliveClient) Context() context.Context

Context provides a mock function with given fields:

func (*PeerDataNode_KeepAliveClient) Header

func (_m *PeerDataNode_KeepAliveClient) Header() (metadata.MD, error)

Header provides a mock function with given fields:

func (*PeerDataNode_KeepAliveClient) Recv

func (_m *PeerDataNode_KeepAliveClient) Recv() (*rpc.KeepAliveResponse, error)

Recv provides a mock function with given fields:

func (*PeerDataNode_KeepAliveClient) RecvMsg

func (_m *PeerDataNode_KeepAliveClient) RecvMsg(m interface{}) error

RecvMsg provides a mock function with given fields: m

func (*PeerDataNode_KeepAliveClient) Send

func (_m *PeerDataNode_KeepAliveClient) Send(_a0 *rpc.Session) error

Send provides a mock function with given fields: _a0

func (*PeerDataNode_KeepAliveClient) SendMsg

func (_m *PeerDataNode_KeepAliveClient) SendMsg(m interface{}) error

SendMsg provides a mock function with given fields: m

func (*PeerDataNode_KeepAliveClient) Trailer

func (_m *PeerDataNode_KeepAliveClient) Trailer() metadata.MD

Trailer provides a mock function with given fields: