mock_types

package
v0.0.0-...-211e212 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 28, 2021 License: GPL-3.0 Imports: 7 Imported by: 0

Documentation

Overview

Package mock_types is a generated GoMock package.

Package mock_types is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockCacheClient 

type MockCacheClient struct {
	// contains filtered or unexported fields
}

MockCacheClient is a mock of CacheClient interface.

func NewMockCacheClient 

func NewMockCacheClient(ctrl *gomock.Controller) *MockCacheClient

NewMockCacheClient creates a new mock instance.

func (*MockCacheClient) EXPECT 

func (m *MockCacheClient) EXPECT() *MockCacheClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCacheClient) Pull 

func (m *MockCacheClient) Pull(ctx context.Context, in *types.PullRequest, opts ...grpc.CallOption) (*types.CacheObject, error)

Pull mocks base method.

func (*MockCacheClient) Push 

func (m *MockCacheClient) Push(ctx context.Context, in *types.PushRequest, opts ...grpc.CallOption) (*types.Empty, error)

Push mocks base method.

func (*MockCacheClient) Query 

func (m *MockCacheClient) Query(ctx context.Context, in *types.QueryRequest, opts ...grpc.CallOption) (*types.QueryResponse, error)

Query mocks base method.

func (*MockCacheClient) Sync 

func (m *MockCacheClient) Sync(ctx context.Context, in *types.SyncRequest, opts ...grpc.CallOption) (types.Cache_SyncClient, error)

Sync mocks base method.

type MockCacheClientMockRecorder 

type MockCacheClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockCacheClientMockRecorder is the mock recorder for MockCacheClient.

func (*MockCacheClientMockRecorder) Pull 

func (mr *MockCacheClientMockRecorder) Pull(ctx, in interface{}, opts ...interface{}) *gomock.Call

Pull indicates an expected call of Pull.

func (*MockCacheClientMockRecorder) Push 

func (mr *MockCacheClientMockRecorder) Push(ctx, in interface{}, opts ...interface{}) *gomock.Call

Push indicates an expected call of Push.

func (*MockCacheClientMockRecorder) Query 

func (mr *MockCacheClientMockRecorder) Query(ctx, in interface{}, opts ...interface{}) *gomock.Call

Query indicates an expected call of Query.

func (*MockCacheClientMockRecorder) Sync 

func (mr *MockCacheClientMockRecorder) Sync(ctx, in interface{}, opts ...interface{}) *gomock.Call

Sync indicates an expected call of Sync.

type MockCacheServer 

type MockCacheServer struct {
	// contains filtered or unexported fields
}

MockCacheServer is a mock of CacheServer interface.

func NewMockCacheServer 

func NewMockCacheServer(ctrl *gomock.Controller) *MockCacheServer

NewMockCacheServer creates a new mock instance.

func (*MockCacheServer) EXPECT 

func (m *MockCacheServer) EXPECT() *MockCacheServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCacheServer) Pull 

func (m *MockCacheServer) Pull(arg0 context.Context, arg1 *types.PullRequest) (*types.CacheObject, error)

Pull mocks base method.

func (*MockCacheServer) Push 

func (m *MockCacheServer) Push(arg0 context.Context, arg1 *types.PushRequest) (*types.Empty, error)

Push mocks base method.

func (*MockCacheServer) Query 

func (m *MockCacheServer) Query(arg0 context.Context, arg1 *types.QueryRequest) (*types.QueryResponse, error)

Query mocks base method.

func (*MockCacheServer) Sync 

func (m *MockCacheServer) Sync(arg0 *types.SyncRequest, arg1 types.Cache_SyncServer) error

Sync mocks base method.

type MockCacheServerMockRecorder 

type MockCacheServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockCacheServerMockRecorder is the mock recorder for MockCacheServer.

func (*MockCacheServerMockRecorder) Pull 

func (mr *MockCacheServerMockRecorder) Pull(arg0, arg1 interface{}) *gomock.Call

Pull indicates an expected call of Pull.

func (*MockCacheServerMockRecorder) Push 

func (mr *MockCacheServerMockRecorder) Push(arg0, arg1 interface{}) *gomock.Call

Push indicates an expected call of Push.

func (*MockCacheServerMockRecorder) Query 

func (mr *MockCacheServerMockRecorder) Query(arg0, arg1 interface{}) *gomock.Call

Query indicates an expected call of Query.

func (*MockCacheServerMockRecorder) Sync 

func (mr *MockCacheServerMockRecorder) Sync(arg0, arg1 interface{}) *gomock.Call

Sync indicates an expected call of Sync.

type MockCache_SyncClient 

type MockCache_SyncClient struct {
	// contains filtered or unexported fields
}

MockCache_SyncClient is a mock of Cache_SyncClient interface.

func NewMockCache_SyncClient 

func NewMockCache_SyncClient(ctrl *gomock.Controller) *MockCache_SyncClient

NewMockCache_SyncClient creates a new mock instance.

func (*MockCache_SyncClient) CloseSend 

func (m *MockCache_SyncClient) CloseSend() error

CloseSend mocks base method.

func (*MockCache_SyncClient) Context 

func (m *MockCache_SyncClient) Context() context.Context

Context mocks base method.

func (*MockCache_SyncClient) EXPECT 

func (m *MockCache_SyncClient) EXPECT() *MockCache_SyncClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCache_SyncClient) Header 

func (m *MockCache_SyncClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockCache_SyncClient) Recv 

func (m *MockCache_SyncClient) Recv() (*types.CacheObject, error)

Recv mocks base method.

func (*MockCache_SyncClient) RecvMsg 

func (m_2 *MockCache_SyncClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockCache_SyncClient) SendMsg 

func (m_2 *MockCache_SyncClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockCache_SyncClient) Trailer 

func (m *MockCache_SyncClient) Trailer() metadata.MD

Trailer mocks base method.

type MockCache_SyncClientMockRecorder 

type MockCache_SyncClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockCache_SyncClientMockRecorder is the mock recorder for MockCache_SyncClient.

func (*MockCache_SyncClientMockRecorder) CloseSend 

func (mr *MockCache_SyncClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockCache_SyncClientMockRecorder) Context 

func (mr *MockCache_SyncClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockCache_SyncClientMockRecorder) Header 

func (mr *MockCache_SyncClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockCache_SyncClientMockRecorder) Recv 

func (mr *MockCache_SyncClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockCache_SyncClientMockRecorder) RecvMsg 

func (mr *MockCache_SyncClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockCache_SyncClientMockRecorder) SendMsg 

func (mr *MockCache_SyncClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockCache_SyncClientMockRecorder) Trailer 

func (mr *MockCache_SyncClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockCache_SyncServer 

type MockCache_SyncServer struct {
	// contains filtered or unexported fields
}

MockCache_SyncServer is a mock of Cache_SyncServer interface.

func NewMockCache_SyncServer 

func NewMockCache_SyncServer(ctrl *gomock.Controller) *MockCache_SyncServer

NewMockCache_SyncServer creates a new mock instance.

func (*MockCache_SyncServer) Context 

func (m *MockCache_SyncServer) Context() context.Context

Context mocks base method.

func (*MockCache_SyncServer) EXPECT 

func (m *MockCache_SyncServer) EXPECT() *MockCache_SyncServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockCache_SyncServer) RecvMsg 

func (m_2 *MockCache_SyncServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockCache_SyncServer) Send 

func (m *MockCache_SyncServer) Send(arg0 *types.CacheObject) error

Send mocks base method.

func (*MockCache_SyncServer) SendHeader 

func (m *MockCache_SyncServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockCache_SyncServer) SendMsg 

func (m_2 *MockCache_SyncServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockCache_SyncServer) SetHeader 

func (m *MockCache_SyncServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockCache_SyncServer) SetTrailer 

func (m *MockCache_SyncServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockCache_SyncServerMockRecorder 

type MockCache_SyncServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockCache_SyncServerMockRecorder is the mock recorder for MockCache_SyncServer.

func (*MockCache_SyncServerMockRecorder) Context 

func (mr *MockCache_SyncServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockCache_SyncServerMockRecorder) RecvMsg 

func (mr *MockCache_SyncServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockCache_SyncServerMockRecorder) Send 

func (mr *MockCache_SyncServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockCache_SyncServerMockRecorder) SendHeader 

func (mr *MockCache_SyncServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockCache_SyncServerMockRecorder) SendMsg 

func (mr *MockCache_SyncServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockCache_SyncServerMockRecorder) SetHeader 

func (mr *MockCache_SyncServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockCache_SyncServerMockRecorder) SetTrailer 

func (mr *MockCache_SyncServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockConsumerdClient 

type MockConsumerdClient struct {
	// contains filtered or unexported fields
}

MockConsumerdClient is a mock of ConsumerdClient interface.

func NewMockConsumerdClient 

func NewMockConsumerdClient(ctrl *gomock.Controller) *MockConsumerdClient

NewMockConsumerdClient creates a new mock instance.

func (*MockConsumerdClient) EXPECT 

func (m *MockConsumerdClient) EXPECT() *MockConsumerdClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumerdClient) GetToolchains 

func (m *MockConsumerdClient) GetToolchains(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.ToolchainList, error)

GetToolchains mocks base method.

func (*MockConsumerdClient) Run 

func (m *MockConsumerdClient) Run(ctx context.Context, in *types.RunRequest, opts ...grpc.CallOption) (*types.RunResponse, error)

Run mocks base method.

type MockConsumerdClientMockRecorder 

type MockConsumerdClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerdClientMockRecorder is the mock recorder for MockConsumerdClient.

func (*MockConsumerdClientMockRecorder) GetToolchains 

func (mr *MockConsumerdClientMockRecorder) GetToolchains(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetToolchains indicates an expected call of GetToolchains.

func (*MockConsumerdClientMockRecorder) Run 

func (mr *MockConsumerdClientMockRecorder) Run(ctx, in interface{}, opts ...interface{}) *gomock.Call

Run indicates an expected call of Run.

type MockConsumerdServer 

type MockConsumerdServer struct {
	// contains filtered or unexported fields
}

MockConsumerdServer is a mock of ConsumerdServer interface.

func NewMockConsumerdServer 

func NewMockConsumerdServer(ctrl *gomock.Controller) *MockConsumerdServer

NewMockConsumerdServer creates a new mock instance.

func (*MockConsumerdServer) EXPECT 

func (m *MockConsumerdServer) EXPECT() *MockConsumerdServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockConsumerdServer) GetToolchains 

func (m *MockConsumerdServer) GetToolchains(arg0 context.Context, arg1 *types.Empty) (*types.ToolchainList, error)

GetToolchains mocks base method.

func (*MockConsumerdServer) Run 

func (m *MockConsumerdServer) Run(arg0 context.Context, arg1 *types.RunRequest) (*types.RunResponse, error)

Run mocks base method.

type MockConsumerdServerMockRecorder 

type MockConsumerdServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockConsumerdServerMockRecorder is the mock recorder for MockConsumerdServer.

func (*MockConsumerdServerMockRecorder) GetToolchains 

func (mr *MockConsumerdServerMockRecorder) GetToolchains(arg0, arg1 interface{}) *gomock.Call

GetToolchains indicates an expected call of GetToolchains.

func (*MockConsumerdServerMockRecorder) Run 

func (mr *MockConsumerdServerMockRecorder) Run(arg0, arg1 interface{}) *gomock.Call

Run indicates an expected call of Run.

type MockMonitorClient 

type MockMonitorClient struct {
	// contains filtered or unexported fields
}

MockMonitorClient is a mock of MonitorClient interface.

func NewMockMonitorClient 

func NewMockMonitorClient(ctrl *gomock.Controller) *MockMonitorClient

NewMockMonitorClient creates a new mock instance.

func (*MockMonitorClient) EXPECT 

func (m *MockMonitorClient) EXPECT() *MockMonitorClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMonitorClient) GetBuckets 

func (m *MockMonitorClient) GetBuckets(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.BucketList, error)

GetBuckets mocks base method.

func (*MockMonitorClient) GetKeys 

func (m *MockMonitorClient) GetKeys(ctx context.Context, in *types.Bucket, opts ...grpc.CallOption) (*types.KeyList, error)

GetKeys mocks base method.

func (*MockMonitorClient) GetMetric 

func (m *MockMonitorClient) GetMetric(ctx context.Context, in *types.Key, opts ...grpc.CallOption) (*types.Metric, error)

GetMetric mocks base method.

func (*MockMonitorClient) Listen 

func (m *MockMonitorClient) Listen(ctx context.Context, in *types.Key, opts ...grpc.CallOption) (types.Monitor_ListenClient, error)

Listen mocks base method.

func (*MockMonitorClient) Stream 

func (m *MockMonitorClient) Stream(ctx context.Context, opts ...grpc.CallOption) (types.Monitor_StreamClient, error)

Stream mocks base method.

func (*MockMonitorClient) Whois 

func (m *MockMonitorClient) Whois(ctx context.Context, in *types.WhoisRequest, opts ...grpc.CallOption) (*types.WhoisResponse, error)

Whois mocks base method.

type MockMonitorClientMockRecorder 

type MockMonitorClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockMonitorClientMockRecorder is the mock recorder for MockMonitorClient.

func (*MockMonitorClientMockRecorder) GetBuckets 

func (mr *MockMonitorClientMockRecorder) GetBuckets(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetBuckets indicates an expected call of GetBuckets.

func (*MockMonitorClientMockRecorder) GetKeys 

func (mr *MockMonitorClientMockRecorder) GetKeys(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetKeys indicates an expected call of GetKeys.

func (*MockMonitorClientMockRecorder) GetMetric 

func (mr *MockMonitorClientMockRecorder) GetMetric(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetMetric indicates an expected call of GetMetric.

func (*MockMonitorClientMockRecorder) Listen 

func (mr *MockMonitorClientMockRecorder) Listen(ctx, in interface{}, opts ...interface{}) *gomock.Call

Listen indicates an expected call of Listen.

func (*MockMonitorClientMockRecorder) Stream 

func (mr *MockMonitorClientMockRecorder) Stream(ctx interface{}, opts ...interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockMonitorClientMockRecorder) Whois 

func (mr *MockMonitorClientMockRecorder) Whois(ctx, in interface{}, opts ...interface{}) *gomock.Call

Whois indicates an expected call of Whois.

type MockMonitorServer 

type MockMonitorServer struct {
	// contains filtered or unexported fields
}

MockMonitorServer is a mock of MonitorServer interface.

func NewMockMonitorServer 

func NewMockMonitorServer(ctrl *gomock.Controller) *MockMonitorServer

NewMockMonitorServer creates a new mock instance.

func (*MockMonitorServer) EXPECT 

func (m *MockMonitorServer) EXPECT() *MockMonitorServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMonitorServer) GetBuckets 

func (m *MockMonitorServer) GetBuckets(arg0 context.Context, arg1 *types.Empty) (*types.BucketList, error)

GetBuckets mocks base method.

func (*MockMonitorServer) GetKeys 

func (m *MockMonitorServer) GetKeys(arg0 context.Context, arg1 *types.Bucket) (*types.KeyList, error)

GetKeys mocks base method.

func (*MockMonitorServer) GetMetric 

func (m *MockMonitorServer) GetMetric(arg0 context.Context, arg1 *types.Key) (*types.Metric, error)

GetMetric mocks base method.

func (*MockMonitorServer) Listen 

func (m *MockMonitorServer) Listen(arg0 *types.Key, arg1 types.Monitor_ListenServer) error

Listen mocks base method.

func (*MockMonitorServer) Stream 

func (m *MockMonitorServer) Stream(arg0 types.Monitor_StreamServer) error

Stream mocks base method.

func (*MockMonitorServer) Whois 

func (m *MockMonitorServer) Whois(arg0 context.Context, arg1 *types.WhoisRequest) (*types.WhoisResponse, error)

Whois mocks base method.

type MockMonitorServerMockRecorder 

type MockMonitorServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockMonitorServerMockRecorder is the mock recorder for MockMonitorServer.

func (*MockMonitorServerMockRecorder) GetBuckets 

func (mr *MockMonitorServerMockRecorder) GetBuckets(arg0, arg1 interface{}) *gomock.Call

GetBuckets indicates an expected call of GetBuckets.

func (*MockMonitorServerMockRecorder) GetKeys 

func (mr *MockMonitorServerMockRecorder) GetKeys(arg0, arg1 interface{}) *gomock.Call

GetKeys indicates an expected call of GetKeys.

func (*MockMonitorServerMockRecorder) GetMetric 

func (mr *MockMonitorServerMockRecorder) GetMetric(arg0, arg1 interface{}) *gomock.Call

GetMetric indicates an expected call of GetMetric.

func (*MockMonitorServerMockRecorder) Listen 

func (mr *MockMonitorServerMockRecorder) Listen(arg0, arg1 interface{}) *gomock.Call

Listen indicates an expected call of Listen.

func (*MockMonitorServerMockRecorder) Stream 

func (mr *MockMonitorServerMockRecorder) Stream(arg0 interface{}) *gomock.Call

Stream indicates an expected call of Stream.

func (*MockMonitorServerMockRecorder) Whois 

func (mr *MockMonitorServerMockRecorder) Whois(arg0, arg1 interface{}) *gomock.Call

Whois indicates an expected call of Whois.

type MockMonitor_ListenClient 

type MockMonitor_ListenClient struct {
	// contains filtered or unexported fields
}

MockMonitor_ListenClient is a mock of Monitor_ListenClient interface.

func NewMockMonitor_ListenClient 

func NewMockMonitor_ListenClient(ctrl *gomock.Controller) *MockMonitor_ListenClient

NewMockMonitor_ListenClient creates a new mock instance.

func (*MockMonitor_ListenClient) CloseSend 

func (m *MockMonitor_ListenClient) CloseSend() error

CloseSend mocks base method.

func (*MockMonitor_ListenClient) Context 

func (m *MockMonitor_ListenClient) Context() context.Context

Context mocks base method.

func (*MockMonitor_ListenClient) EXPECT 

func (m *MockMonitor_ListenClient) EXPECT() *MockMonitor_ListenClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMonitor_ListenClient) Header 

func (m *MockMonitor_ListenClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockMonitor_ListenClient) Recv 

func (m *MockMonitor_ListenClient) Recv() (*anypb.Any, error)

Recv mocks base method.

func (*MockMonitor_ListenClient) RecvMsg 

func (m_2 *MockMonitor_ListenClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockMonitor_ListenClient) SendMsg 

func (m_2 *MockMonitor_ListenClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockMonitor_ListenClient) Trailer 

func (m *MockMonitor_ListenClient) Trailer() metadata.MD

Trailer mocks base method.

type MockMonitor_ListenClientMockRecorder 

type MockMonitor_ListenClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockMonitor_ListenClientMockRecorder is the mock recorder for MockMonitor_ListenClient.

func (*MockMonitor_ListenClientMockRecorder) CloseSend 

func (mr *MockMonitor_ListenClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockMonitor_ListenClientMockRecorder) Context 

func (mr *MockMonitor_ListenClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockMonitor_ListenClientMockRecorder) Header 

func (mr *MockMonitor_ListenClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockMonitor_ListenClientMockRecorder) Recv 

func (mr *MockMonitor_ListenClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockMonitor_ListenClientMockRecorder) RecvMsg 

func (mr *MockMonitor_ListenClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockMonitor_ListenClientMockRecorder) SendMsg 

func (mr *MockMonitor_ListenClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockMonitor_ListenClientMockRecorder) Trailer 

func (mr *MockMonitor_ListenClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockMonitor_ListenServer 

type MockMonitor_ListenServer struct {
	// contains filtered or unexported fields
}

MockMonitor_ListenServer is a mock of Monitor_ListenServer interface.

func NewMockMonitor_ListenServer 

func NewMockMonitor_ListenServer(ctrl *gomock.Controller) *MockMonitor_ListenServer

NewMockMonitor_ListenServer creates a new mock instance.

func (*MockMonitor_ListenServer) Context 

func (m *MockMonitor_ListenServer) Context() context.Context

Context mocks base method.

func (*MockMonitor_ListenServer) EXPECT 

func (m *MockMonitor_ListenServer) EXPECT() *MockMonitor_ListenServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMonitor_ListenServer) RecvMsg 

func (m_2 *MockMonitor_ListenServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockMonitor_ListenServer) Send 

func (m *MockMonitor_ListenServer) Send(arg0 *anypb.Any) error

Send mocks base method.

func (*MockMonitor_ListenServer) SendHeader 

func (m *MockMonitor_ListenServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockMonitor_ListenServer) SendMsg 

func (m_2 *MockMonitor_ListenServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockMonitor_ListenServer) SetHeader 

func (m *MockMonitor_ListenServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockMonitor_ListenServer) SetTrailer 

func (m *MockMonitor_ListenServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockMonitor_ListenServerMockRecorder 

type MockMonitor_ListenServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockMonitor_ListenServerMockRecorder is the mock recorder for MockMonitor_ListenServer.

func (*MockMonitor_ListenServerMockRecorder) Context 

func (mr *MockMonitor_ListenServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockMonitor_ListenServerMockRecorder) RecvMsg 

func (mr *MockMonitor_ListenServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockMonitor_ListenServerMockRecorder) Send 

func (mr *MockMonitor_ListenServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockMonitor_ListenServerMockRecorder) SendHeader 

func (mr *MockMonitor_ListenServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockMonitor_ListenServerMockRecorder) SendMsg 

func (mr *MockMonitor_ListenServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockMonitor_ListenServerMockRecorder) SetHeader 

func (mr *MockMonitor_ListenServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockMonitor_ListenServerMockRecorder) SetTrailer 

func (mr *MockMonitor_ListenServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockMonitor_StreamClient 

type MockMonitor_StreamClient struct {
	// contains filtered or unexported fields
}

MockMonitor_StreamClient is a mock of Monitor_StreamClient interface.

func NewMockMonitor_StreamClient 

func NewMockMonitor_StreamClient(ctrl *gomock.Controller) *MockMonitor_StreamClient

NewMockMonitor_StreamClient creates a new mock instance.

func (*MockMonitor_StreamClient) CloseSend 

func (m *MockMonitor_StreamClient) CloseSend() error

CloseSend mocks base method.

func (*MockMonitor_StreamClient) Context 

func (m *MockMonitor_StreamClient) Context() context.Context

Context mocks base method.

func (*MockMonitor_StreamClient) EXPECT 

func (m *MockMonitor_StreamClient) EXPECT() *MockMonitor_StreamClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMonitor_StreamClient) Header 

func (m *MockMonitor_StreamClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockMonitor_StreamClient) Recv 

func (m *MockMonitor_StreamClient) Recv() (*types.Empty, error)

Recv mocks base method.

func (*MockMonitor_StreamClient) RecvMsg 

func (m_2 *MockMonitor_StreamClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockMonitor_StreamClient) Send 

func (m *MockMonitor_StreamClient) Send(arg0 *types.Metric) error

Send mocks base method.

func (*MockMonitor_StreamClient) SendMsg 

func (m_2 *MockMonitor_StreamClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockMonitor_StreamClient) Trailer 

func (m *MockMonitor_StreamClient) Trailer() metadata.MD

Trailer mocks base method.

type MockMonitor_StreamClientMockRecorder 

type MockMonitor_StreamClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockMonitor_StreamClientMockRecorder is the mock recorder for MockMonitor_StreamClient.

func (*MockMonitor_StreamClientMockRecorder) CloseSend 

func (mr *MockMonitor_StreamClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockMonitor_StreamClientMockRecorder) Context 

func (mr *MockMonitor_StreamClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockMonitor_StreamClientMockRecorder) Header 

func (mr *MockMonitor_StreamClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockMonitor_StreamClientMockRecorder) Recv 

func (mr *MockMonitor_StreamClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockMonitor_StreamClientMockRecorder) RecvMsg 

func (mr *MockMonitor_StreamClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockMonitor_StreamClientMockRecorder) Send 

func (mr *MockMonitor_StreamClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockMonitor_StreamClientMockRecorder) SendMsg 

func (mr *MockMonitor_StreamClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockMonitor_StreamClientMockRecorder) Trailer 

func (mr *MockMonitor_StreamClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockMonitor_StreamServer 

type MockMonitor_StreamServer struct {
	// contains filtered or unexported fields
}

MockMonitor_StreamServer is a mock of Monitor_StreamServer interface.

func NewMockMonitor_StreamServer 

func NewMockMonitor_StreamServer(ctrl *gomock.Controller) *MockMonitor_StreamServer

NewMockMonitor_StreamServer creates a new mock instance.

func (*MockMonitor_StreamServer) Context 

func (m *MockMonitor_StreamServer) Context() context.Context

Context mocks base method.

func (*MockMonitor_StreamServer) EXPECT 

func (m *MockMonitor_StreamServer) EXPECT() *MockMonitor_StreamServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockMonitor_StreamServer) Recv 

func (m *MockMonitor_StreamServer) Recv() (*types.Metric, error)

Recv mocks base method.

func (*MockMonitor_StreamServer) RecvMsg 

func (m_2 *MockMonitor_StreamServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockMonitor_StreamServer) Send 

func (m *MockMonitor_StreamServer) Send(arg0 *types.Empty) error

Send mocks base method.

func (*MockMonitor_StreamServer) SendHeader 

func (m *MockMonitor_StreamServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockMonitor_StreamServer) SendMsg 

func (m_2 *MockMonitor_StreamServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockMonitor_StreamServer) SetHeader 

func (m *MockMonitor_StreamServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockMonitor_StreamServer) SetTrailer 

func (m *MockMonitor_StreamServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockMonitor_StreamServerMockRecorder 

type MockMonitor_StreamServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockMonitor_StreamServerMockRecorder is the mock recorder for MockMonitor_StreamServer.

func (*MockMonitor_StreamServerMockRecorder) Context 

func (mr *MockMonitor_StreamServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockMonitor_StreamServerMockRecorder) Recv 

func (mr *MockMonitor_StreamServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockMonitor_StreamServerMockRecorder) RecvMsg 

func (mr *MockMonitor_StreamServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockMonitor_StreamServerMockRecorder) Send 

func (mr *MockMonitor_StreamServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockMonitor_StreamServerMockRecorder) SendHeader 

func (mr *MockMonitor_StreamServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockMonitor_StreamServerMockRecorder) SendMsg 

func (mr *MockMonitor_StreamServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockMonitor_StreamServerMockRecorder) SetHeader 

func (mr *MockMonitor_StreamServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockMonitor_StreamServerMockRecorder) SetTrailer 

func (mr *MockMonitor_StreamServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockSchedulerClient 

type MockSchedulerClient struct {
	// contains filtered or unexported fields
}

MockSchedulerClient is a mock of SchedulerClient interface.

func NewMockSchedulerClient 

func NewMockSchedulerClient(ctrl *gomock.Controller) *MockSchedulerClient

NewMockSchedulerClient creates a new mock instance.

func (*MockSchedulerClient) Compile 

func (m *MockSchedulerClient) Compile(ctx context.Context, in *types.CompileRequest, opts ...grpc.CallOption) (*types.CompileResponse, error)

Compile mocks base method.

func (*MockSchedulerClient) EXPECT 

func (m *MockSchedulerClient) EXPECT() *MockSchedulerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSchedulerClient) GetRoutes 

func (m *MockSchedulerClient) GetRoutes(ctx context.Context, in *types.Empty, opts ...grpc.CallOption) (*types.RouteList, error)

GetRoutes mocks base method.

func (*MockSchedulerClient) StreamIncomingTasks 

func (m *MockSchedulerClient) StreamIncomingTasks(ctx context.Context, opts ...grpc.CallOption) (types.Scheduler_StreamIncomingTasksClient, error)

StreamIncomingTasks mocks base method.

func (*MockSchedulerClient) StreamOutgoingTasks 

func (m *MockSchedulerClient) StreamOutgoingTasks(ctx context.Context, opts ...grpc.CallOption) (types.Scheduler_StreamOutgoingTasksClient, error)

StreamOutgoingTasks mocks base method.

type MockSchedulerClientMockRecorder 

type MockSchedulerClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockSchedulerClientMockRecorder is the mock recorder for MockSchedulerClient.

func (*MockSchedulerClientMockRecorder) Compile 

func (mr *MockSchedulerClientMockRecorder) Compile(ctx, in interface{}, opts ...interface{}) *gomock.Call

Compile indicates an expected call of Compile.

func (*MockSchedulerClientMockRecorder) GetRoutes 

func (mr *MockSchedulerClientMockRecorder) GetRoutes(ctx, in interface{}, opts ...interface{}) *gomock.Call

GetRoutes indicates an expected call of GetRoutes.

func (*MockSchedulerClientMockRecorder) StreamIncomingTasks 

func (mr *MockSchedulerClientMockRecorder) StreamIncomingTasks(ctx interface{}, opts ...interface{}) *gomock.Call

StreamIncomingTasks indicates an expected call of StreamIncomingTasks.

func (*MockSchedulerClientMockRecorder) StreamOutgoingTasks 

func (mr *MockSchedulerClientMockRecorder) StreamOutgoingTasks(ctx interface{}, opts ...interface{}) *gomock.Call

StreamOutgoingTasks indicates an expected call of StreamOutgoingTasks.

type MockSchedulerServer 

type MockSchedulerServer struct {
	// contains filtered or unexported fields
}

MockSchedulerServer is a mock of SchedulerServer interface.

func NewMockSchedulerServer 

func NewMockSchedulerServer(ctrl *gomock.Controller) *MockSchedulerServer

NewMockSchedulerServer creates a new mock instance.

func (*MockSchedulerServer) Compile 

func (m *MockSchedulerServer) Compile(arg0 context.Context, arg1 *types.CompileRequest) (*types.CompileResponse, error)

Compile mocks base method.

func (*MockSchedulerServer) EXPECT 

func (m *MockSchedulerServer) EXPECT() *MockSchedulerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSchedulerServer) GetRoutes 

func (m *MockSchedulerServer) GetRoutes(arg0 context.Context, arg1 *types.Empty) (*types.RouteList, error)

GetRoutes mocks base method.

func (*MockSchedulerServer) StreamIncomingTasks 

func (m *MockSchedulerServer) StreamIncomingTasks(arg0 types.Scheduler_StreamIncomingTasksServer) error

StreamIncomingTasks mocks base method.

func (*MockSchedulerServer) StreamOutgoingTasks 

func (m *MockSchedulerServer) StreamOutgoingTasks(arg0 types.Scheduler_StreamOutgoingTasksServer) error

StreamOutgoingTasks mocks base method.

type MockSchedulerServerMockRecorder 

type MockSchedulerServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockSchedulerServerMockRecorder is the mock recorder for MockSchedulerServer.

func (*MockSchedulerServerMockRecorder) Compile 

func (mr *MockSchedulerServerMockRecorder) Compile(arg0, arg1 interface{}) *gomock.Call

Compile indicates an expected call of Compile.

func (*MockSchedulerServerMockRecorder) GetRoutes 

func (mr *MockSchedulerServerMockRecorder) GetRoutes(arg0, arg1 interface{}) *gomock.Call

GetRoutes indicates an expected call of GetRoutes.

func (*MockSchedulerServerMockRecorder) StreamIncomingTasks 

func (mr *MockSchedulerServerMockRecorder) StreamIncomingTasks(arg0 interface{}) *gomock.Call

StreamIncomingTasks indicates an expected call of StreamIncomingTasks.

func (*MockSchedulerServerMockRecorder) StreamOutgoingTasks 

func (mr *MockSchedulerServerMockRecorder) StreamOutgoingTasks(arg0 interface{}) *gomock.Call

StreamOutgoingTasks indicates an expected call of StreamOutgoingTasks.

type MockScheduler_StreamIncomingTasksClient 

type MockScheduler_StreamIncomingTasksClient struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamIncomingTasksClient is a mock of Scheduler_StreamIncomingTasksClient interface.

func NewMockScheduler_StreamIncomingTasksClient 

func NewMockScheduler_StreamIncomingTasksClient(ctrl *gomock.Controller) *MockScheduler_StreamIncomingTasksClient

NewMockScheduler_StreamIncomingTasksClient creates a new mock instance.

func (*MockScheduler_StreamIncomingTasksClient) CloseSend 

func (m *MockScheduler_StreamIncomingTasksClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) Context 

func (m *MockScheduler_StreamIncomingTasksClient) Context() context.Context

Context mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) EXPECT 

func (m *MockScheduler_StreamIncomingTasksClient) EXPECT() *MockScheduler_StreamIncomingTasksClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockScheduler_StreamIncomingTasksClient) Header 

func (m *MockScheduler_StreamIncomingTasksClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) Recv 

func (m *MockScheduler_StreamIncomingTasksClient) Recv() (*types.CompileRequest, error)

Recv mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) RecvMsg 

func (m_2 *MockScheduler_StreamIncomingTasksClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) Send 

func (m *MockScheduler_StreamIncomingTasksClient) Send(arg0 *types.CompileResponse) error

Send mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) SendMsg 

func (m_2 *MockScheduler_StreamIncomingTasksClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_StreamIncomingTasksClient) Trailer 

func (m *MockScheduler_StreamIncomingTasksClient) Trailer() metadata.MD

Trailer mocks base method.

type MockScheduler_StreamIncomingTasksClientMockRecorder 

type MockScheduler_StreamIncomingTasksClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamIncomingTasksClientMockRecorder is the mock recorder for MockScheduler_StreamIncomingTasksClient.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) CloseSend 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) Context 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) Header 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) Recv 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) RecvMsg 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) Send 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) SendMsg 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_StreamIncomingTasksClientMockRecorder) Trailer 

func (mr *MockScheduler_StreamIncomingTasksClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockScheduler_StreamIncomingTasksServer 

type MockScheduler_StreamIncomingTasksServer struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamIncomingTasksServer is a mock of Scheduler_StreamIncomingTasksServer interface.

func NewMockScheduler_StreamIncomingTasksServer 

func NewMockScheduler_StreamIncomingTasksServer(ctrl *gomock.Controller) *MockScheduler_StreamIncomingTasksServer

NewMockScheduler_StreamIncomingTasksServer creates a new mock instance.

func (*MockScheduler_StreamIncomingTasksServer) Context 

func (m *MockScheduler_StreamIncomingTasksServer) Context() context.Context

Context mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) EXPECT 

func (m *MockScheduler_StreamIncomingTasksServer) EXPECT() *MockScheduler_StreamIncomingTasksServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockScheduler_StreamIncomingTasksServer) Recv 

func (m *MockScheduler_StreamIncomingTasksServer) Recv() (*types.CompileResponse, error)

Recv mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) RecvMsg 

func (m_2 *MockScheduler_StreamIncomingTasksServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) Send 

func (m *MockScheduler_StreamIncomingTasksServer) Send(arg0 *types.CompileRequest) error

Send mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) SendHeader 

func (m *MockScheduler_StreamIncomingTasksServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) SendMsg 

func (m_2 *MockScheduler_StreamIncomingTasksServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) SetHeader 

func (m *MockScheduler_StreamIncomingTasksServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockScheduler_StreamIncomingTasksServer) SetTrailer 

func (m *MockScheduler_StreamIncomingTasksServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockScheduler_StreamIncomingTasksServerMockRecorder 

type MockScheduler_StreamIncomingTasksServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamIncomingTasksServerMockRecorder is the mock recorder for MockScheduler_StreamIncomingTasksServer.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) Context 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) Recv 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) RecvMsg 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) Send 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) SendHeader 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) SendMsg 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) SetHeader 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_StreamIncomingTasksServerMockRecorder) SetTrailer 

func (mr *MockScheduler_StreamIncomingTasksServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockScheduler_StreamOutgoingTasksClient 

type MockScheduler_StreamOutgoingTasksClient struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamOutgoingTasksClient is a mock of Scheduler_StreamOutgoingTasksClient interface.

func NewMockScheduler_StreamOutgoingTasksClient 

func NewMockScheduler_StreamOutgoingTasksClient(ctrl *gomock.Controller) *MockScheduler_StreamOutgoingTasksClient

NewMockScheduler_StreamOutgoingTasksClient creates a new mock instance.

func (*MockScheduler_StreamOutgoingTasksClient) CloseSend 

func (m *MockScheduler_StreamOutgoingTasksClient) CloseSend() error

CloseSend mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) Context 

func (m *MockScheduler_StreamOutgoingTasksClient) Context() context.Context

Context mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) EXPECT 

func (m *MockScheduler_StreamOutgoingTasksClient) EXPECT() *MockScheduler_StreamOutgoingTasksClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockScheduler_StreamOutgoingTasksClient) Header 

func (m *MockScheduler_StreamOutgoingTasksClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) Recv 

func (m *MockScheduler_StreamOutgoingTasksClient) Recv() (*types.CompileResponse, error)

Recv mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) RecvMsg 

func (m_2 *MockScheduler_StreamOutgoingTasksClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) Send 

func (m *MockScheduler_StreamOutgoingTasksClient) Send(arg0 *types.CompileRequest) error

Send mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) SendMsg 

func (m_2 *MockScheduler_StreamOutgoingTasksClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_StreamOutgoingTasksClient) Trailer 

func (m *MockScheduler_StreamOutgoingTasksClient) Trailer() metadata.MD

Trailer mocks base method.

type MockScheduler_StreamOutgoingTasksClientMockRecorder 

type MockScheduler_StreamOutgoingTasksClientMockRecorder struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamOutgoingTasksClientMockRecorder is the mock recorder for MockScheduler_StreamOutgoingTasksClient.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) CloseSend 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) Context 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) Header 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) Recv 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) RecvMsg 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) Send 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) SendMsg 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_StreamOutgoingTasksClientMockRecorder) Trailer 

func (mr *MockScheduler_StreamOutgoingTasksClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockScheduler_StreamOutgoingTasksServer 

type MockScheduler_StreamOutgoingTasksServer struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamOutgoingTasksServer is a mock of Scheduler_StreamOutgoingTasksServer interface.

func NewMockScheduler_StreamOutgoingTasksServer 

func NewMockScheduler_StreamOutgoingTasksServer(ctrl *gomock.Controller) *MockScheduler_StreamOutgoingTasksServer

NewMockScheduler_StreamOutgoingTasksServer creates a new mock instance.

func (*MockScheduler_StreamOutgoingTasksServer) Context 

func (m *MockScheduler_StreamOutgoingTasksServer) Context() context.Context

Context mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) EXPECT 

func (m *MockScheduler_StreamOutgoingTasksServer) EXPECT() *MockScheduler_StreamOutgoingTasksServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockScheduler_StreamOutgoingTasksServer) Recv 

func (m *MockScheduler_StreamOutgoingTasksServer) Recv() (*types.CompileRequest, error)

Recv mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) RecvMsg 

func (m_2 *MockScheduler_StreamOutgoingTasksServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) Send 

func (m *MockScheduler_StreamOutgoingTasksServer) Send(arg0 *types.CompileResponse) error

Send mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) SendHeader 

func (m *MockScheduler_StreamOutgoingTasksServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) SendMsg 

func (m_2 *MockScheduler_StreamOutgoingTasksServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) SetHeader 

func (m *MockScheduler_StreamOutgoingTasksServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockScheduler_StreamOutgoingTasksServer) SetTrailer 

func (m *MockScheduler_StreamOutgoingTasksServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockScheduler_StreamOutgoingTasksServerMockRecorder 

type MockScheduler_StreamOutgoingTasksServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockScheduler_StreamOutgoingTasksServerMockRecorder is the mock recorder for MockScheduler_StreamOutgoingTasksServer.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) Context 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) Recv 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) RecvMsg 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) Send 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) SendHeader 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) SendMsg 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) SetHeader 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockScheduler_StreamOutgoingTasksServerMockRecorder) SetTrailer 

func (mr *MockScheduler_StreamOutgoingTasksServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockUnsafeCacheServer 

type MockUnsafeCacheServer struct {
	// contains filtered or unexported fields
}

MockUnsafeCacheServer is a mock of UnsafeCacheServer interface.

func NewMockUnsafeCacheServer 

func NewMockUnsafeCacheServer(ctrl *gomock.Controller) *MockUnsafeCacheServer

NewMockUnsafeCacheServer creates a new mock instance.

func (*MockUnsafeCacheServer) EXPECT 

func (m *MockUnsafeCacheServer) EXPECT() *MockUnsafeCacheServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeCacheServerMockRecorder 

type MockUnsafeCacheServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeCacheServerMockRecorder is the mock recorder for MockUnsafeCacheServer.

type MockUnsafeConsumerdServer 

type MockUnsafeConsumerdServer struct {
	// contains filtered or unexported fields
}

MockUnsafeConsumerdServer is a mock of UnsafeConsumerdServer interface.

func NewMockUnsafeConsumerdServer 

func NewMockUnsafeConsumerdServer(ctrl *gomock.Controller) *MockUnsafeConsumerdServer

NewMockUnsafeConsumerdServer creates a new mock instance.

func (*MockUnsafeConsumerdServer) EXPECT 

func (m *MockUnsafeConsumerdServer) EXPECT() *MockUnsafeConsumerdServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeConsumerdServerMockRecorder 

type MockUnsafeConsumerdServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeConsumerdServerMockRecorder is the mock recorder for MockUnsafeConsumerdServer.

type MockUnsafeMonitorServer 

type MockUnsafeMonitorServer struct {
	// contains filtered or unexported fields
}

MockUnsafeMonitorServer is a mock of UnsafeMonitorServer interface.

func NewMockUnsafeMonitorServer 

func NewMockUnsafeMonitorServer(ctrl *gomock.Controller) *MockUnsafeMonitorServer

NewMockUnsafeMonitorServer creates a new mock instance.

func (*MockUnsafeMonitorServer) EXPECT 

func (m *MockUnsafeMonitorServer) EXPECT() *MockUnsafeMonitorServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeMonitorServerMockRecorder 

type MockUnsafeMonitorServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeMonitorServerMockRecorder is the mock recorder for MockUnsafeMonitorServer.

type MockUnsafeSchedulerServer 

type MockUnsafeSchedulerServer struct {
	// contains filtered or unexported fields
}

MockUnsafeSchedulerServer is a mock of UnsafeSchedulerServer interface.

func NewMockUnsafeSchedulerServer 

func NewMockUnsafeSchedulerServer(ctrl *gomock.Controller) *MockUnsafeSchedulerServer

NewMockUnsafeSchedulerServer creates a new mock instance.

func (*MockUnsafeSchedulerServer) EXPECT 

func (m *MockUnsafeSchedulerServer) EXPECT() *MockUnsafeSchedulerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeSchedulerServerMockRecorder 

type MockUnsafeSchedulerServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockUnsafeSchedulerServerMockRecorder is the mock recorder for MockUnsafeSchedulerServer.

type MockisCompileResponse_Data 

type MockisCompileResponse_Data struct {
	// contains filtered or unexported fields
}

MockisCompileResponse_Data is a mock of isCompileResponse_Data interface.

func NewMockisCompileResponse_Data 

func NewMockisCompileResponse_Data(ctrl *gomock.Controller) *MockisCompileResponse_Data

NewMockisCompileResponse_Data creates a new mock instance.

func (*MockisCompileResponse_Data) EXPECT 

func (m *MockisCompileResponse_Data) EXPECT() *MockisCompileResponse_DataMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockisCompileResponse_DataMockRecorder 

type MockisCompileResponse_DataMockRecorder struct {
	// contains filtered or unexported fields
}

MockisCompileResponse_DataMockRecorder is the mock recorder for MockisCompileResponse_Data.

type MockisRunRequest_Compiler 

type MockisRunRequest_Compiler struct {
	// contains filtered or unexported fields
}

MockisRunRequest_Compiler is a mock of isRunRequest_Compiler interface.

func NewMockisRunRequest_Compiler 

func NewMockisRunRequest_Compiler(ctrl *gomock.Controller) *MockisRunRequest_Compiler

NewMockisRunRequest_Compiler creates a new mock instance.

func (*MockisRunRequest_Compiler) EXPECT 

func (m *MockisRunRequest_Compiler) EXPECT() *MockisRunRequest_CompilerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockisRunRequest_CompilerMockRecorder 

type MockisRunRequest_CompilerMockRecorder struct {
	// contains filtered or unexported fields
}

MockisRunRequest_CompilerMockRecorder is the mock recorder for MockisRunRequest_Compiler.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.