mock_tunnel_server

package
v16.8.0-rc3 Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

Code generated by MockGen. DO NOT EDIT. Source: gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/tunnel/server (interfaces: Tracker,Handler,FindHandle,Tunnel,PollingQuerier,Finder)

Generated by this command: 

mockgen -typed -destination tunnel.go -package mock_tunnel_server gitlab.com/gitlab-org/cluster-integration/gitlab-agent/v16/internal/tunnel/server Tracker,Handler,FindHandle,Tunnel,PollingQuerier,Finder

Package mock_tunnel_server is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type FindHandleDoneCall 

type FindHandleDoneCall struct {
	*gomock.Call
}

FindHandleDoneCall wrap *gomock.Call

func (*FindHandleDoneCall) Do 

func (c *FindHandleDoneCall) Do(f func(context.Context)) *FindHandleDoneCall

Do rewrite *gomock.Call.Do

func (*FindHandleDoneCall) DoAndReturn 

func (c *FindHandleDoneCall) DoAndReturn(f func(context.Context)) *FindHandleDoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*FindHandleDoneCall) Return 

func (c *FindHandleDoneCall) Return() *FindHandleDoneCall

Return rewrite *gomock.Call.Return

type FindHandleGetCall 

type FindHandleGetCall struct {
	*gomock.Call
}

FindHandleGetCall wrap *gomock.Call

func (*FindHandleGetCall) Do 

func (c *FindHandleGetCall) Do(f func(context.Context) (server.Tunnel, error)) *FindHandleGetCall

Do rewrite *gomock.Call.Do

func (*FindHandleGetCall) DoAndReturn 

func (c *FindHandleGetCall) DoAndReturn(f func(context.Context) (server.Tunnel, error)) *FindHandleGetCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*FindHandleGetCall) Return 

func (c *FindHandleGetCall) Return(arg0 server.Tunnel, arg1 error) *FindHandleGetCall

Return rewrite *gomock.Call.Return

type FinderFindTunnelCall 

type FinderFindTunnelCall struct {
	*gomock.Call
}

FinderFindTunnelCall wrap *gomock.Call

func (*FinderFindTunnelCall) Do 

func (c *FinderFindTunnelCall) Do(f func(context.Context, int64, string, string) (bool, server.FindHandle)) *FinderFindTunnelCall

Do rewrite *gomock.Call.Do

func (*FinderFindTunnelCall) DoAndReturn 

func (c *FinderFindTunnelCall) DoAndReturn(f func(context.Context, int64, string, string) (bool, server.FindHandle)) *FinderFindTunnelCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*FinderFindTunnelCall) Return 

func (c *FinderFindTunnelCall) Return(arg0 bool, arg1 server.FindHandle) *FinderFindTunnelCall

Return rewrite *gomock.Call.Return

type HandlerHandleTunnelCall 

type HandlerHandleTunnelCall struct {
	*gomock.Call
}

HandlerHandleTunnelCall wrap *gomock.Call

func (*HandlerHandleTunnelCall) Do 

func (c *HandlerHandleTunnelCall) Do(f func(context.Context, *api.AgentInfo, rpc.ReverseTunnel_ConnectServer) error) *HandlerHandleTunnelCall

Do rewrite *gomock.Call.Do

func (*HandlerHandleTunnelCall) DoAndReturn 

func (c *HandlerHandleTunnelCall) DoAndReturn(f func(context.Context, *api.AgentInfo, rpc.ReverseTunnel_ConnectServer) error) *HandlerHandleTunnelCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*HandlerHandleTunnelCall) Return 

func (c *HandlerHandleTunnelCall) Return(arg0 error) *HandlerHandleTunnelCall

Return rewrite *gomock.Call.Return

type MockFindHandle 

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

MockFindHandle is a mock of FindHandle interface.

func NewMockFindHandle 

func NewMockFindHandle(ctrl *gomock.Controller) *MockFindHandle

NewMockFindHandle creates a new mock instance.

func (*MockFindHandle) Done 

func (m *MockFindHandle) Done(arg0 context.Context)

Done mocks base method.

func (*MockFindHandle) EXPECT 

func (m *MockFindHandle) EXPECT() *MockFindHandleMockRecorder

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

func (*MockFindHandle) Get 

func (m *MockFindHandle) Get(arg0 context.Context) (server.Tunnel, error)

Get mocks base method.

type MockFindHandleMockRecorder 

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

MockFindHandleMockRecorder is the mock recorder for MockFindHandle.

func (*MockFindHandleMockRecorder) Done 

func (mr *MockFindHandleMockRecorder) Done(arg0 any) *FindHandleDoneCall

Done indicates an expected call of Done.

func (*MockFindHandleMockRecorder) Get 

func (mr *MockFindHandleMockRecorder) Get(arg0 any) *FindHandleGetCall

Get indicates an expected call of Get.

type MockFinder 

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

MockFinder is a mock of Finder interface.

func NewMockFinder 

func NewMockFinder(ctrl *gomock.Controller) *MockFinder

NewMockFinder creates a new mock instance.

func (*MockFinder) EXPECT 

func (m *MockFinder) EXPECT() *MockFinderMockRecorder

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

func (*MockFinder) FindTunnel 

func (m *MockFinder) FindTunnel(arg0 context.Context, arg1 int64, arg2, arg3 string) (bool, server.FindHandle)

FindTunnel mocks base method.

type MockFinderMockRecorder 

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

MockFinderMockRecorder is the mock recorder for MockFinder.

func (*MockFinderMockRecorder) FindTunnel 

func (mr *MockFinderMockRecorder) FindTunnel(arg0, arg1, arg2, arg3 any) *FinderFindTunnelCall

FindTunnel indicates an expected call of FindTunnel.

type MockHandler 

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

MockHandler is a mock of Handler interface.

func NewMockHandler 

func NewMockHandler(ctrl *gomock.Controller) *MockHandler

NewMockHandler creates a new mock instance.

func (*MockHandler) EXPECT 

func (m *MockHandler) EXPECT() *MockHandlerMockRecorder

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

func (*MockHandler) HandleTunnel 

func (m *MockHandler) HandleTunnel(arg0 context.Context, arg1 *api.AgentInfo, arg2 rpc.ReverseTunnel_ConnectServer) error

HandleTunnel mocks base method.

type MockHandlerMockRecorder 

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

MockHandlerMockRecorder is the mock recorder for MockHandler.

func (*MockHandlerMockRecorder) HandleTunnel 

func (mr *MockHandlerMockRecorder) HandleTunnel(arg0, arg1, arg2 any) *HandlerHandleTunnelCall

HandleTunnel indicates an expected call of HandleTunnel.

type MockPollingQuerier 

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

MockPollingQuerier is a mock of PollingQuerier interface.

func NewMockPollingQuerier 

func NewMockPollingQuerier(ctrl *gomock.Controller) *MockPollingQuerier

NewMockPollingQuerier creates a new mock instance.

func (*MockPollingQuerier) CachedKasUrlsByAgentId 

func (m *MockPollingQuerier) CachedKasUrlsByAgentId(arg0 int64) []string

CachedKasUrlsByAgentId mocks base method.

func (*MockPollingQuerier) EXPECT 

func (m *MockPollingQuerier) EXPECT() *MockPollingQuerierMockRecorder

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

func (*MockPollingQuerier) PollKasUrlsByAgentId 

func (m *MockPollingQuerier) PollKasUrlsByAgentId(arg0 context.Context, arg1 int64, arg2 server.PollKasUrlsByAgentIdCallback)

PollKasUrlsByAgentId mocks base method.

type MockPollingQuerierMockRecorder 

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

MockPollingQuerierMockRecorder is the mock recorder for MockPollingQuerier.

func (*MockPollingQuerierMockRecorder) CachedKasUrlsByAgentId 

func (mr *MockPollingQuerierMockRecorder) CachedKasUrlsByAgentId(arg0 any) *PollingQuerierCachedKasUrlsByAgentIdCall

CachedKasUrlsByAgentId indicates an expected call of CachedKasUrlsByAgentId.

func (*MockPollingQuerierMockRecorder) PollKasUrlsByAgentId 

func (mr *MockPollingQuerierMockRecorder) PollKasUrlsByAgentId(arg0, arg1, arg2 any) *PollingQuerierPollKasUrlsByAgentIdCall

PollKasUrlsByAgentId indicates an expected call of PollKasUrlsByAgentId.

type MockTracker 

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

MockTracker is a mock of Tracker interface.

func NewMockTracker 

func NewMockTracker(ctrl *gomock.Controller) *MockTracker

NewMockTracker creates a new mock instance.

func (*MockTracker) EXPECT 

func (m *MockTracker) EXPECT() *MockTrackerMockRecorder

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

func (*MockTracker) KasUrlsByAgentId 

func (m *MockTracker) KasUrlsByAgentId(arg0 context.Context, arg1 int64) ([]string, error)

KasUrlsByAgentId mocks base method.

func (*MockTracker) Refresh 

func (m *MockTracker) Refresh(arg0 context.Context, arg1 time.Duration, arg2 ...int64) error

Refresh mocks base method.

func (*MockTracker) RegisterTunnel 

func (m *MockTracker) RegisterTunnel(arg0 context.Context, arg1 time.Duration, arg2 int64) error

RegisterTunnel mocks base method.

func (*MockTracker) UnregisterTunnel 

func (m *MockTracker) UnregisterTunnel(arg0 context.Context, arg1 int64) error

UnregisterTunnel mocks base method.

type MockTrackerMockRecorder 

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

MockTrackerMockRecorder is the mock recorder for MockTracker.

func (*MockTrackerMockRecorder) KasUrlsByAgentId 

func (mr *MockTrackerMockRecorder) KasUrlsByAgentId(arg0, arg1 any) *TrackerKasUrlsByAgentIdCall

KasUrlsByAgentId indicates an expected call of KasUrlsByAgentId.

func (*MockTrackerMockRecorder) Refresh 

func (mr *MockTrackerMockRecorder) Refresh(arg0, arg1 any, arg2 ...any) *TrackerRefreshCall

Refresh indicates an expected call of Refresh.

func (*MockTrackerMockRecorder) RegisterTunnel 

func (mr *MockTrackerMockRecorder) RegisterTunnel(arg0, arg1, arg2 any) *TrackerRegisterTunnelCall

RegisterTunnel indicates an expected call of RegisterTunnel.

func (*MockTrackerMockRecorder) UnregisterTunnel 

func (mr *MockTrackerMockRecorder) UnregisterTunnel(arg0, arg1 any) *TrackerUnregisterTunnelCall

UnregisterTunnel indicates an expected call of UnregisterTunnel.

type MockTunnel 

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

MockTunnel is a mock of Tunnel interface.

func NewMockTunnel 

func NewMockTunnel(ctrl *gomock.Controller) *MockTunnel

NewMockTunnel creates a new mock instance.

func (*MockTunnel) Done 

func (m *MockTunnel) Done(arg0 context.Context)

Done mocks base method.

func (*MockTunnel) EXPECT 

func (m *MockTunnel) EXPECT() *MockTunnelMockRecorder

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

func (*MockTunnel) ForwardStream 

func (m *MockTunnel) ForwardStream(arg0 *zap.Logger, arg1 server.RpcApi, arg2 grpc.ServerStream, arg3 server.DataCallback) error

ForwardStream mocks base method.

type MockTunnelMockRecorder 

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

MockTunnelMockRecorder is the mock recorder for MockTunnel.

func (*MockTunnelMockRecorder) Done 

func (mr *MockTunnelMockRecorder) Done(arg0 any) *TunnelDoneCall

Done indicates an expected call of Done.

func (*MockTunnelMockRecorder) ForwardStream 

func (mr *MockTunnelMockRecorder) ForwardStream(arg0, arg1, arg2, arg3 any) *TunnelForwardStreamCall

ForwardStream indicates an expected call of ForwardStream.

type PollingQuerierCachedKasUrlsByAgentIdCall 

type PollingQuerierCachedKasUrlsByAgentIdCall struct {
	*gomock.Call
}

PollingQuerierCachedKasUrlsByAgentIdCall wrap *gomock.Call

func (*PollingQuerierCachedKasUrlsByAgentIdCall) Do 

func (c *PollingQuerierCachedKasUrlsByAgentIdCall) Do(f func(int64) []string) *PollingQuerierCachedKasUrlsByAgentIdCall

Do rewrite *gomock.Call.Do

func (*PollingQuerierCachedKasUrlsByAgentIdCall) DoAndReturn 

func (c *PollingQuerierCachedKasUrlsByAgentIdCall) DoAndReturn(f func(int64) []string) *PollingQuerierCachedKasUrlsByAgentIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PollingQuerierCachedKasUrlsByAgentIdCall) Return 

func (c *PollingQuerierCachedKasUrlsByAgentIdCall) Return(arg0 []string) *PollingQuerierCachedKasUrlsByAgentIdCall

Return rewrite *gomock.Call.Return

type PollingQuerierPollKasUrlsByAgentIdCall 

type PollingQuerierPollKasUrlsByAgentIdCall struct {
	*gomock.Call
}

PollingQuerierPollKasUrlsByAgentIdCall wrap *gomock.Call

func (*PollingQuerierPollKasUrlsByAgentIdCall) Do 

func (c *PollingQuerierPollKasUrlsByAgentIdCall) Do(f func(context.Context, int64, server.PollKasUrlsByAgentIdCallback)) *PollingQuerierPollKasUrlsByAgentIdCall

Do rewrite *gomock.Call.Do

func (*PollingQuerierPollKasUrlsByAgentIdCall) DoAndReturn 

func (c *PollingQuerierPollKasUrlsByAgentIdCall) DoAndReturn(f func(context.Context, int64, server.PollKasUrlsByAgentIdCallback)) *PollingQuerierPollKasUrlsByAgentIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*PollingQuerierPollKasUrlsByAgentIdCall) Return 

func (c *PollingQuerierPollKasUrlsByAgentIdCall) Return() *PollingQuerierPollKasUrlsByAgentIdCall

Return rewrite *gomock.Call.Return

type TrackerKasUrlsByAgentIdCall 

type TrackerKasUrlsByAgentIdCall struct {
	*gomock.Call
}

TrackerKasUrlsByAgentIdCall wrap *gomock.Call

func (*TrackerKasUrlsByAgentIdCall) Do 

func (c *TrackerKasUrlsByAgentIdCall) Do(f func(context.Context, int64) ([]string, error)) *TrackerKasUrlsByAgentIdCall

Do rewrite *gomock.Call.Do

func (*TrackerKasUrlsByAgentIdCall) DoAndReturn 

func (c *TrackerKasUrlsByAgentIdCall) DoAndReturn(f func(context.Context, int64) ([]string, error)) *TrackerKasUrlsByAgentIdCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*TrackerKasUrlsByAgentIdCall) Return 

func (c *TrackerKasUrlsByAgentIdCall) Return(arg0 []string, arg1 error) *TrackerKasUrlsByAgentIdCall

Return rewrite *gomock.Call.Return

type TrackerRefreshCall 

type TrackerRefreshCall struct {
	*gomock.Call
}

TrackerRefreshCall wrap *gomock.Call

func (*TrackerRefreshCall) Do 

func (c *TrackerRefreshCall) Do(f func(context.Context, time.Duration, ...int64) error) *TrackerRefreshCall

Do rewrite *gomock.Call.Do

func (*TrackerRefreshCall) DoAndReturn 

func (c *TrackerRefreshCall) DoAndReturn(f func(context.Context, time.Duration, ...int64) error) *TrackerRefreshCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*TrackerRefreshCall) Return 

func (c *TrackerRefreshCall) Return(arg0 error) *TrackerRefreshCall

Return rewrite *gomock.Call.Return

type TrackerRegisterTunnelCall 

type TrackerRegisterTunnelCall struct {
	*gomock.Call
}

TrackerRegisterTunnelCall wrap *gomock.Call

func (*TrackerRegisterTunnelCall) Do 

func (c *TrackerRegisterTunnelCall) Do(f func(context.Context, time.Duration, int64) error) *TrackerRegisterTunnelCall

Do rewrite *gomock.Call.Do

func (*TrackerRegisterTunnelCall) DoAndReturn 

func (c *TrackerRegisterTunnelCall) DoAndReturn(f func(context.Context, time.Duration, int64) error) *TrackerRegisterTunnelCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*TrackerRegisterTunnelCall) Return 

func (c *TrackerRegisterTunnelCall) Return(arg0 error) *TrackerRegisterTunnelCall

Return rewrite *gomock.Call.Return

type TrackerUnregisterTunnelCall 

type TrackerUnregisterTunnelCall struct {
	*gomock.Call
}

TrackerUnregisterTunnelCall wrap *gomock.Call

func (*TrackerUnregisterTunnelCall) Do 

func (c *TrackerUnregisterTunnelCall) Do(f func(context.Context, int64) error) *TrackerUnregisterTunnelCall

Do rewrite *gomock.Call.Do

func (*TrackerUnregisterTunnelCall) DoAndReturn 

func (c *TrackerUnregisterTunnelCall) DoAndReturn(f func(context.Context, int64) error) *TrackerUnregisterTunnelCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*TrackerUnregisterTunnelCall) Return 

func (c *TrackerUnregisterTunnelCall) Return(arg0 error) *TrackerUnregisterTunnelCall

Return rewrite *gomock.Call.Return

type TunnelDoneCall 

type TunnelDoneCall struct {
	*gomock.Call
}

TunnelDoneCall wrap *gomock.Call

func (*TunnelDoneCall) Do 

func (c *TunnelDoneCall) Do(f func(context.Context)) *TunnelDoneCall

Do rewrite *gomock.Call.Do

func (*TunnelDoneCall) DoAndReturn 

func (c *TunnelDoneCall) DoAndReturn(f func(context.Context)) *TunnelDoneCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*TunnelDoneCall) Return 

func (c *TunnelDoneCall) Return() *TunnelDoneCall

Return rewrite *gomock.Call.Return

type TunnelForwardStreamCall 

type TunnelForwardStreamCall struct {
	*gomock.Call
}

TunnelForwardStreamCall wrap *gomock.Call

func (*TunnelForwardStreamCall) Do 

func (c *TunnelForwardStreamCall) Do(f func(*zap.Logger, server.RpcApi, grpc.ServerStream, server.DataCallback) error) *TunnelForwardStreamCall

Do rewrite *gomock.Call.Do

func (*TunnelForwardStreamCall) DoAndReturn 

func (c *TunnelForwardStreamCall) DoAndReturn(f func(*zap.Logger, server.RpcApi, grpc.ServerStream, server.DataCallback) error) *TunnelForwardStreamCall

DoAndReturn rewrite *gomock.Call.DoAndReturn

func (*TunnelForwardStreamCall) Return 

func (c *TunnelForwardStreamCall) Return(arg0 error) *TunnelForwardStreamCall

Return rewrite *gomock.Call.Return

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.