mock

package
v1.6.0 Latest Latest
Warning

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

 Go to latest Published: Aug 17, 2023 License: Apache-2.0 Imports: 14 Imported by: 0

README

how to mock

go get this lib:

https://github.com/golang/mock

mock gen example:

mockgen -source=../types/stream.go -package=mock > stream.go

Documentation

Overview

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Package mock is a generated GoMock package.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type MockABI added in v0.22.0 

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

MockABI is a mock of ABI interface.

func NewMockABI added in v0.22.0 

func NewMockABI(ctrl *gomock.Controller) *MockABI

NewMockABI creates a new mock instance.

func (*MockABI) EXPECT added in v0.22.0 

func (m *MockABI) EXPECT() *MockABIMockRecorder

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

func (*MockABI) GetABIExports added in v0.22.0 

func (m *MockABI) GetABIExports() interface{}

GetABIExports mocks base method.

func (*MockABI) GetABIImports added in v0.22.0 

func (m *MockABI) GetABIImports() interface{}

GetABIImports mocks base method.

func (*MockABI) Name added in v0.22.0 

func (m *MockABI) Name() string

Name mocks base method.

func (*MockABI) OnInstanceCreate added in v0.22.0 

func (m *MockABI) OnInstanceCreate(arg0 common.WasmInstance)

OnInstanceCreate mocks base method.

func (*MockABI) OnInstanceDestroy added in v0.22.0 

func (m *MockABI) OnInstanceDestroy(arg0 common.WasmInstance)

OnInstanceDestroy mocks base method.

func (*MockABI) OnInstanceStart added in v0.22.0 

func (m *MockABI) OnInstanceStart(arg0 common.WasmInstance)

OnInstanceStart mocks base method.

func (*MockABI) SetABIImports added in v0.22.0 

func (m *MockABI) SetABIImports(arg0 interface{})

SetABIImports mocks base method.

type MockABIHandler added in v0.22.0 

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

MockABIHandler is a mock of ABIHandler interface.

func NewMockABIHandler added in v0.22.0 

func NewMockABIHandler(ctrl *gomock.Controller) *MockABIHandler

NewMockABIHandler creates a new mock instance.

func (*MockABIHandler) EXPECT added in v0.22.0 

func (m *MockABIHandler) EXPECT() *MockABIHandlerMockRecorder

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

func (*MockABIHandler) OnInstanceCreate added in v0.22.0 

func (m *MockABIHandler) OnInstanceCreate(arg0 common.WasmInstance)

OnInstanceCreate mocks base method.

func (*MockABIHandler) OnInstanceDestroy added in v0.22.0 

func (m *MockABIHandler) OnInstanceDestroy(arg0 common.WasmInstance)

OnInstanceDestroy mocks base method.

func (*MockABIHandler) OnInstanceStart added in v0.22.0 

func (m *MockABIHandler) OnInstanceStart(arg0 common.WasmInstance)

OnInstanceStart mocks base method.

type MockABIHandlerMockRecorder added in v0.22.0 

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

MockABIHandlerMockRecorder is the mock recorder for MockABIHandler.

func (*MockABIHandlerMockRecorder) OnInstanceCreate added in v0.22.0 

func (mr *MockABIHandlerMockRecorder) OnInstanceCreate(arg0 interface{}) *gomock.Call

OnInstanceCreate indicates an expected call of OnInstanceCreate.

func (*MockABIHandlerMockRecorder) OnInstanceDestroy added in v0.22.0 

func (mr *MockABIHandlerMockRecorder) OnInstanceDestroy(arg0 interface{}) *gomock.Call

OnInstanceDestroy indicates an expected call of OnInstanceDestroy.

func (*MockABIHandlerMockRecorder) OnInstanceStart added in v0.22.0 

func (mr *MockABIHandlerMockRecorder) OnInstanceStart(arg0 interface{}) *gomock.Call

OnInstanceStart indicates an expected call of OnInstanceStart.

type MockABIMockRecorder added in v0.22.0 

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

MockABIMockRecorder is the mock recorder for MockABI.

func (*MockABIMockRecorder) GetABIExports added in v0.22.0 

func (mr *MockABIMockRecorder) GetABIExports() *gomock.Call

GetABIExports indicates an expected call of GetABIExports.

func (*MockABIMockRecorder) GetABIImports added in v0.22.0 

func (mr *MockABIMockRecorder) GetABIImports() *gomock.Call

GetABIImports indicates an expected call of GetABIImports.

func (*MockABIMockRecorder) Name added in v0.22.0 

func (mr *MockABIMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockABIMockRecorder) OnInstanceCreate added in v0.22.0 

func (mr *MockABIMockRecorder) OnInstanceCreate(arg0 interface{}) *gomock.Call

OnInstanceCreate indicates an expected call of OnInstanceCreate.

func (*MockABIMockRecorder) OnInstanceDestroy added in v0.22.0 

func (mr *MockABIMockRecorder) OnInstanceDestroy(arg0 interface{}) *gomock.Call

OnInstanceDestroy indicates an expected call of OnInstanceDestroy.

func (*MockABIMockRecorder) OnInstanceStart added in v0.22.0 

func (mr *MockABIMockRecorder) OnInstanceStart(arg0 interface{}) *gomock.Call

OnInstanceStart indicates an expected call of OnInstanceStart.

func (*MockABIMockRecorder) SetABIImports added in v0.22.0 

func (mr *MockABIMockRecorder) SetABIImports(arg0 interface{}) *gomock.Call

SetABIImports indicates an expected call of SetABIImports.

type MockApplication added in v0.27.0 

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

MockApplication is a mock of Application interface.

func NewMockApplication added in v0.27.0 

func NewMockApplication(ctrl *gomock.Controller) *MockApplication

NewMockApplication creates a new mock instance.

func (*MockApplication) Close added in v0.27.0 

func (m *MockApplication) Close(arg0 bool)

Close mocks base method.

func (*MockApplication) EXPECT added in v0.27.0 

func (m *MockApplication) EXPECT() *MockApplicationMockRecorder

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

func (*MockApplication) InheritConnections added in v0.27.0 

func (m *MockApplication) InheritConnections() error

InheritConnections mocks base method.

func (*MockApplication) Init added in v0.27.0 

func (m *MockApplication) Init(arg0 *v2.MOSNConfig) error

Init mocks base method.

func (*MockApplication) IsFromUpgrade added in v1.0.0 

func (m *MockApplication) IsFromUpgrade() bool

IsFromUpgrade mocks base method.

func (*MockApplication) Shutdown added in v0.27.0 

func (m *MockApplication) Shutdown() error

Shutdown mocks base method.

func (*MockApplication) Start added in v0.27.0 

func (m *MockApplication) Start()

Start mocks base method.

type MockApplicationMockRecorder added in v0.27.0 

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

MockApplicationMockRecorder is the mock recorder for MockApplication.

func (*MockApplicationMockRecorder) Close added in v0.27.0 

func (mr *MockApplicationMockRecorder) Close(arg0 interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockApplicationMockRecorder) InheritConnections added in v0.27.0 

func (mr *MockApplicationMockRecorder) InheritConnections() *gomock.Call

InheritConnections indicates an expected call of InheritConnections.

func (*MockApplicationMockRecorder) Init added in v0.27.0 

func (mr *MockApplicationMockRecorder) Init(arg0 interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockApplicationMockRecorder) IsFromUpgrade added in v1.0.0 

func (mr *MockApplicationMockRecorder) IsFromUpgrade() *gomock.Call

IsFromUpgrade indicates an expected call of IsFromUpgrade.

func (*MockApplicationMockRecorder) Shutdown added in v0.27.0 

func (mr *MockApplicationMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockApplicationMockRecorder) Start added in v0.27.0 

func (mr *MockApplicationMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

type MockClientStreamConnection 

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

MockClientStreamConnection is a mock of ClientStreamConnection interface.

func NewMockClientStreamConnection 

func NewMockClientStreamConnection(ctrl *gomock.Controller) *MockClientStreamConnection

NewMockClientStreamConnection creates a new mock instance.

func (*MockClientStreamConnection) ActiveStreamsNum 

func (m *MockClientStreamConnection) ActiveStreamsNum() int

ActiveStreamsNum mocks base method.

func (*MockClientStreamConnection) CheckReasonError 

func (m *MockClientStreamConnection) CheckReasonError(connected bool, event api.ConnectionEvent) (types.StreamResetReason, bool)

CheckReasonError mocks base method.

func (*MockClientStreamConnection) Dispatch 

func (m *MockClientStreamConnection) Dispatch(buffer buffer.IoBuffer)

Dispatch mocks base method.

func (*MockClientStreamConnection) EXPECT 

func (m *MockClientStreamConnection) EXPECT() *MockClientStreamConnectionMockRecorder

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

func (*MockClientStreamConnection) EnableWorkerPool added in v0.17.0 

func (m *MockClientStreamConnection) EnableWorkerPool() bool

EnableWorkerPool mocks base method.

func (*MockClientStreamConnection) GoAway 

func (m *MockClientStreamConnection) GoAway()

GoAway mocks base method.

func (*MockClientStreamConnection) NewStream 

func (m *MockClientStreamConnection) NewStream(ctx context.Context, responseReceiveListener types.StreamReceiveListener) types.StreamSender

NewStream mocks base method.

func (*MockClientStreamConnection) Protocol 

func (m *MockClientStreamConnection) Protocol() api.ProtocolName

Protocol mocks base method.

func (*MockClientStreamConnection) Reset 

func (m *MockClientStreamConnection) Reset(reason types.StreamResetReason)

Reset mocks base method.

type MockClientStreamConnectionMockRecorder 

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

MockClientStreamConnectionMockRecorder is the mock recorder for MockClientStreamConnection.

func (*MockClientStreamConnectionMockRecorder) ActiveStreamsNum 

func (mr *MockClientStreamConnectionMockRecorder) ActiveStreamsNum() *gomock.Call

ActiveStreamsNum indicates an expected call of ActiveStreamsNum.

func (*MockClientStreamConnectionMockRecorder) CheckReasonError 

func (mr *MockClientStreamConnectionMockRecorder) CheckReasonError(connected, event interface{}) *gomock.Call

CheckReasonError indicates an expected call of CheckReasonError.

func (*MockClientStreamConnectionMockRecorder) Dispatch 

func (mr *MockClientStreamConnectionMockRecorder) Dispatch(buffer interface{}) *gomock.Call

Dispatch indicates an expected call of Dispatch.

func (*MockClientStreamConnectionMockRecorder) EnableWorkerPool added in v0.17.0 

func (mr *MockClientStreamConnectionMockRecorder) EnableWorkerPool() *gomock.Call

EnableWorkerPool indicates an expected call of EnableWorkerPool.

func (*MockClientStreamConnectionMockRecorder) GoAway 

func (mr *MockClientStreamConnectionMockRecorder) GoAway() *gomock.Call

GoAway indicates an expected call of GoAway.

func (*MockClientStreamConnectionMockRecorder) NewStream 

func (mr *MockClientStreamConnectionMockRecorder) NewStream(ctx, responseReceiveListener interface{}) *gomock.Call

NewStream indicates an expected call of NewStream.

func (*MockClientStreamConnectionMockRecorder) Protocol 

func (mr *MockClientStreamConnectionMockRecorder) Protocol() *gomock.Call

Protocol indicates an expected call of Protocol.

func (*MockClientStreamConnectionMockRecorder) Reset 

func (mr *MockClientStreamConnectionMockRecorder) Reset(reason interface{}) *gomock.Call

Reset indicates an expected call of Reset.

type MockCluster added in v0.17.0 

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

MockCluster is a mock of Cluster interface.

func NewMockCluster added in v0.17.0 

func NewMockCluster(ctrl *gomock.Controller) *MockCluster

NewMockCluster creates a new mock instance.

func (*MockCluster) AddHealthCheckCallbacks added in v0.17.0 

func (m *MockCluster) AddHealthCheckCallbacks(cb types.HealthCheckCb)

AddHealthCheckCallbacks mocks base method.

func (*MockCluster) EXPECT added in v0.17.0 

func (m *MockCluster) EXPECT() *MockClusterMockRecorder

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

func (*MockCluster) Snapshot added in v0.17.0 

func (m *MockCluster) Snapshot() types.ClusterSnapshot

Snapshot mocks base method.

func (*MockCluster) StopHealthChecking added in v0.17.0 

func (m *MockCluster) StopHealthChecking()

StopHealthChecking mocks base method.

func (*MockCluster) UpdateHosts added in v0.17.0 

func (m *MockCluster) UpdateHosts(arg0 types.HostSet)

UpdateHosts mocks base method.

type MockClusterConfigFactoryCb added in v0.17.0 

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

MockClusterConfigFactoryCb is a mock of ClusterConfigFactoryCb interface.

func NewMockClusterConfigFactoryCb added in v0.17.0 

func NewMockClusterConfigFactoryCb(ctrl *gomock.Controller) *MockClusterConfigFactoryCb

NewMockClusterConfigFactoryCb creates a new mock instance.

func (*MockClusterConfigFactoryCb) EXPECT added in v0.17.0 

func (m *MockClusterConfigFactoryCb) EXPECT() *MockClusterConfigFactoryCbMockRecorder

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

func (*MockClusterConfigFactoryCb) UpdateClusterConfig added in v0.17.0 

func (m *MockClusterConfigFactoryCb) UpdateClusterConfig(configs []v2.Cluster) error

UpdateClusterConfig mocks base method.

type MockClusterConfigFactoryCbMockRecorder added in v0.17.0 

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

MockClusterConfigFactoryCbMockRecorder is the mock recorder for MockClusterConfigFactoryCb.

func (*MockClusterConfigFactoryCbMockRecorder) UpdateClusterConfig added in v0.17.0 

func (mr *MockClusterConfigFactoryCbMockRecorder) UpdateClusterConfig(configs interface{}) *gomock.Call

UpdateClusterConfig indicates an expected call of UpdateClusterConfig.

type MockClusterHostFactoryCb added in v0.17.0 

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

MockClusterHostFactoryCb is a mock of ClusterHostFactoryCb interface.

func NewMockClusterHostFactoryCb added in v0.17.0 

func NewMockClusterHostFactoryCb(ctrl *gomock.Controller) *MockClusterHostFactoryCb

NewMockClusterHostFactoryCb creates a new mock instance.

func (*MockClusterHostFactoryCb) EXPECT added in v0.17.0 

func (m *MockClusterHostFactoryCb) EXPECT() *MockClusterHostFactoryCbMockRecorder

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

func (*MockClusterHostFactoryCb) UpdateClusterHost added in v0.17.0 

func (m *MockClusterHostFactoryCb) UpdateClusterHost(cluster string, hosts []v2.Host) error

UpdateClusterHost mocks base method.

type MockClusterHostFactoryCbMockRecorder added in v0.17.0 

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

MockClusterHostFactoryCbMockRecorder is the mock recorder for MockClusterHostFactoryCb.

func (*MockClusterHostFactoryCbMockRecorder) UpdateClusterHost added in v0.17.0 

func (mr *MockClusterHostFactoryCbMockRecorder) UpdateClusterHost(cluster, hosts interface{}) *gomock.Call

UpdateClusterHost indicates an expected call of UpdateClusterHost.

type MockClusterInfo added in v0.17.0 

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

MockClusterInfo is a mock of ClusterInfo interface.

func NewMockClusterInfo added in v0.17.0 

func NewMockClusterInfo(ctrl *gomock.Controller) *MockClusterInfo

NewMockClusterInfo creates a new mock instance.

func (*MockClusterInfo) ClusterType added in v0.17.0 

func (m *MockClusterInfo) ClusterType() v2.ClusterType

ClusterType mocks base method.

func (*MockClusterInfo) ConnBufferLimitBytes added in v0.17.0 

func (m *MockClusterInfo) ConnBufferLimitBytes() uint32

ConnBufferLimitBytes mocks base method.

func (*MockClusterInfo) ConnectTimeout added in v0.17.0 

func (m *MockClusterInfo) ConnectTimeout() time.Duration

ConnectTimeout mocks base method.

func (*MockClusterInfo) EXPECT added in v0.17.0 

func (m *MockClusterInfo) EXPECT() *MockClusterInfoMockRecorder

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

func (*MockClusterInfo) IdleTimeout added in v0.27.0 

func (m *MockClusterInfo) IdleTimeout() time.Duration

IdleTimeout mocks base method.

func (*MockClusterInfo) IsClusterPoolEnable added in v1.5.0 

func (m *MockClusterInfo) IsClusterPoolEnable() bool

IsClusterPoolEnable mocks base method.

func (*MockClusterInfo) LbConfig added in v0.17.0 

func (m *MockClusterInfo) LbConfig() *v2.LbConfig

LbConfig mocks base method.

func (*MockClusterInfo) LbOriDstInfo added in v0.17.0 

func (m *MockClusterInfo) LbOriDstInfo() types.LBOriDstInfo

LbOriDstInfo mocks base method.

func (*MockClusterInfo) LbSubsetInfo added in v0.17.0 

func (m *MockClusterInfo) LbSubsetInfo() types.LBSubsetInfo

LbSubsetInfo mocks base method.

func (*MockClusterInfo) LbType added in v0.17.0 

func (m *MockClusterInfo) LbType() types.LoadBalancerType

LbType mocks base method.

func (*MockClusterInfo) Mark added in v1.2.0 

func (m *MockClusterInfo) Mark() uint32

Mark mocks base method.

func (*MockClusterInfo) MaxRequestsPerConn added in v0.17.0 

func (m *MockClusterInfo) MaxRequestsPerConn() uint32

MaxRequestsPerConn mocks base method.

func (*MockClusterInfo) Name added in v0.17.0 

func (m *MockClusterInfo) Name() string

Name mocks base method.

func (*MockClusterInfo) ResourceManager added in v0.17.0 

func (m *MockClusterInfo) ResourceManager() types.ResourceManager

ResourceManager mocks base method.

func (*MockClusterInfo) SlowStart added in v1.5.0 

func (m *MockClusterInfo) SlowStart() types.SlowStart

SlowStart mocks base method.

func (*MockClusterInfo) Stats added in v0.17.0 

func (m *MockClusterInfo) Stats() *types.ClusterStats

Stats mocks base method.

func (*MockClusterInfo) SubType added in v0.23.0 

func (m *MockClusterInfo) SubType() string

SubType mocks base method.

func (*MockClusterInfo) TLSMng added in v0.17.0 

func (m *MockClusterInfo) TLSMng() types.TLSClientContextManager

TLSMng mocks base method.

type MockClusterInfoMockRecorder added in v0.17.0 

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

MockClusterInfoMockRecorder is the mock recorder for MockClusterInfo.

func (*MockClusterInfoMockRecorder) ClusterType added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) ClusterType() *gomock.Call

ClusterType indicates an expected call of ClusterType.

func (*MockClusterInfoMockRecorder) ConnBufferLimitBytes added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) ConnBufferLimitBytes() *gomock.Call

ConnBufferLimitBytes indicates an expected call of ConnBufferLimitBytes.

func (*MockClusterInfoMockRecorder) ConnectTimeout added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) ConnectTimeout() *gomock.Call

ConnectTimeout indicates an expected call of ConnectTimeout.

func (*MockClusterInfoMockRecorder) IdleTimeout added in v0.27.0 

func (mr *MockClusterInfoMockRecorder) IdleTimeout() *gomock.Call

IdleTimeout indicates an expected call of IdleTimeout.

func (*MockClusterInfoMockRecorder) IsClusterPoolEnable added in v1.5.0 

func (mr *MockClusterInfoMockRecorder) IsClusterPoolEnable() *gomock.Call

IsClusterPoolEnable indicates an expected call of IsClusterPoolEnable.

func (*MockClusterInfoMockRecorder) LbConfig added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) LbConfig() *gomock.Call

LbConfig indicates an expected call of LbConfig.

func (*MockClusterInfoMockRecorder) LbOriDstInfo added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) LbOriDstInfo() *gomock.Call

LbOriDstInfo indicates an expected call of LbOriDstInfo.

func (*MockClusterInfoMockRecorder) LbSubsetInfo added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) LbSubsetInfo() *gomock.Call

LbSubsetInfo indicates an expected call of LbSubsetInfo.

func (*MockClusterInfoMockRecorder) LbType added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) LbType() *gomock.Call

LbType indicates an expected call of LbType.

func (*MockClusterInfoMockRecorder) Mark added in v1.2.0 

func (mr *MockClusterInfoMockRecorder) Mark() *gomock.Call

Mark indicates an expected call of Mark.

func (*MockClusterInfoMockRecorder) MaxRequestsPerConn added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) MaxRequestsPerConn() *gomock.Call

MaxRequestsPerConn indicates an expected call of MaxRequestsPerConn.

func (*MockClusterInfoMockRecorder) Name added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockClusterInfoMockRecorder) ResourceManager added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) ResourceManager() *gomock.Call

ResourceManager indicates an expected call of ResourceManager.

func (*MockClusterInfoMockRecorder) SlowStart added in v1.5.0 

func (mr *MockClusterInfoMockRecorder) SlowStart() *gomock.Call

SlowStart indicates an expected call of SlowStart.

func (*MockClusterInfoMockRecorder) Stats added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) Stats() *gomock.Call

Stats indicates an expected call of Stats.

func (*MockClusterInfoMockRecorder) SubType added in v0.23.0 

func (mr *MockClusterInfoMockRecorder) SubType() *gomock.Call

SubType indicates an expected call of SubType.

func (*MockClusterInfoMockRecorder) TLSMng added in v0.17.0 

func (mr *MockClusterInfoMockRecorder) TLSMng() *gomock.Call

TLSMng indicates an expected call of TLSMng.

type MockClusterManager added in v0.17.0 

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

MockClusterManager is a mock of ClusterManager interface.

func NewMockClusterManager added in v0.17.0 

func NewMockClusterManager(ctrl *gomock.Controller) *MockClusterManager

NewMockClusterManager creates a new mock instance.

func (*MockClusterManager) AddClusterHealthCheckCallbacks added in v0.17.0 

func (m *MockClusterManager) AddClusterHealthCheckCallbacks(name string, cb types.HealthCheckCb) error

AddClusterHealthCheckCallbacks mocks base method.

func (*MockClusterManager) AddOrUpdateClusterAndHost added in v1.1.0 

func (m *MockClusterManager) AddOrUpdateClusterAndHost(cluster v2.Cluster, hosts []v2.Host) error

AddOrUpdateClusterAndHost mocks base method.

func (*MockClusterManager) AddOrUpdatePrimaryCluster added in v0.17.0 

func (m *MockClusterManager) AddOrUpdatePrimaryCluster(cluster v2.Cluster) error

AddOrUpdatePrimaryCluster mocks base method.

func (*MockClusterManager) AppendClusterHosts added in v0.17.0 

func (m *MockClusterManager) AppendClusterHosts(clusterName string, hostConfigs []v2.Host) error

AppendClusterHosts mocks base method.

func (*MockClusterManager) ClusterExist added in v0.17.0 

func (m *MockClusterManager) ClusterExist(clusterName string) bool

ClusterExist mocks base method.

func (*MockClusterManager) ConnPoolForCluster added in v0.17.0 

func (m *MockClusterManager) ConnPoolForCluster(balancerContext types.LoadBalancerContext, snapshot types.ClusterSnapshot, protocol api.ProtocolName) (types.ConnectionPool, types.Host)

ConnPoolForCluster mocks base method.

func (*MockClusterManager) Destroy added in v0.17.0 

func (m *MockClusterManager) Destroy()

Destroy mocks base method.

func (*MockClusterManager) EXPECT added in v0.17.0 

func (m *MockClusterManager) EXPECT() *MockClusterManagerMockRecorder

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

func (*MockClusterManager) GetClusterSnapshot added in v0.17.0 

func (m *MockClusterManager) GetClusterSnapshot(context context.Context, cluster string) types.ClusterSnapshot

GetClusterSnapshot mocks base method.

func (*MockClusterManager) GetTLSManager added in v0.17.0 

func (m *MockClusterManager) GetTLSManager() types.TLSClientContextManager

GetTLSManager mocks base method.

func (*MockClusterManager) PutClusterSnapshot added in v0.17.0 

func (m *MockClusterManager) PutClusterSnapshot(arg0 types.ClusterSnapshot)

PutClusterSnapshot mocks base method.

func (*MockClusterManager) RemoveClusterHosts added in v0.17.0 

func (m *MockClusterManager) RemoveClusterHosts(clusterName string, hosts []string) error

RemoveClusterHosts mocks base method.

func (*MockClusterManager) RemovePrimaryCluster added in v0.17.0 

func (m *MockClusterManager) RemovePrimaryCluster(clusters ...string) error

RemovePrimaryCluster mocks base method.

func (*MockClusterManager) ShutdownConnectionPool added in v0.23.0 

func (m *MockClusterManager) ShutdownConnectionPool(proto types.ProtocolName, addr string)

ShutdownConnectionPool mocks base method.

func (*MockClusterManager) TCPConnForCluster added in v0.17.0 

func (m *MockClusterManager) TCPConnForCluster(balancerContext types.LoadBalancerContext, snapshot types.ClusterSnapshot) types.CreateConnectionData

TCPConnForCluster mocks base method.

func (*MockClusterManager) UDPConnForCluster added in v0.17.0 

func (m *MockClusterManager) UDPConnForCluster(balancerContext types.LoadBalancerContext, snapshot types.ClusterSnapshot) types.CreateConnectionData

UDPConnForCluster mocks base method.

func (*MockClusterManager) UpdateCluster added in v1.1.0 

func (m *MockClusterManager) UpdateCluster(cluster v2.Cluster, clusterHandler types.ClusterUpdateHandler) error

UpdateCluster mocks base method.

func (*MockClusterManager) UpdateClusterHosts added in v0.17.0 

func (m *MockClusterManager) UpdateClusterHosts(cluster string, hosts []v2.Host) error

UpdateClusterHosts mocks base method.

func (*MockClusterManager) UpdateHosts added in v1.1.0 

func (m *MockClusterManager) UpdateHosts(clusterName string, hostConfigs []v2.Host, hostHandler types.HostUpdateHandler) error

UpdateHosts mocks base method.

func (*MockClusterManager) UpdateTLSManager added in v0.17.0 

func (m *MockClusterManager) UpdateTLSManager(arg0 *v2.TLSConfig)

UpdateTLSManager mocks base method.

type MockClusterManagerFilter added in v0.17.0 

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

MockClusterManagerFilter is a mock of ClusterManagerFilter interface.

func NewMockClusterManagerFilter added in v0.17.0 

func NewMockClusterManagerFilter(ctrl *gomock.Controller) *MockClusterManagerFilter

NewMockClusterManagerFilter creates a new mock instance.

func (*MockClusterManagerFilter) EXPECT added in v0.17.0 

func (m *MockClusterManagerFilter) EXPECT() *MockClusterManagerFilterMockRecorder

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

func (*MockClusterManagerFilter) OnCreated added in v0.17.0 

func (m *MockClusterManagerFilter) OnCreated(cccb types.ClusterConfigFactoryCb, chcb types.ClusterHostFactoryCb)

OnCreated mocks base method.

type MockClusterManagerFilterMockRecorder added in v0.17.0 

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

MockClusterManagerFilterMockRecorder is the mock recorder for MockClusterManagerFilter.

func (*MockClusterManagerFilterMockRecorder) OnCreated added in v0.17.0 

func (mr *MockClusterManagerFilterMockRecorder) OnCreated(cccb, chcb interface{}) *gomock.Call

OnCreated indicates an expected call of OnCreated.

type MockClusterManagerMockRecorder added in v0.17.0 

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

MockClusterManagerMockRecorder is the mock recorder for MockClusterManager.

func (*MockClusterManagerMockRecorder) AddClusterHealthCheckCallbacks added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) AddClusterHealthCheckCallbacks(name, cb interface{}) *gomock.Call

AddClusterHealthCheckCallbacks indicates an expected call of AddClusterHealthCheckCallbacks.

func (*MockClusterManagerMockRecorder) AddOrUpdateClusterAndHost added in v1.1.0 

func (mr *MockClusterManagerMockRecorder) AddOrUpdateClusterAndHost(cluster, hosts interface{}) *gomock.Call

AddOrUpdateClusterAndHost indicates an expected call of AddOrUpdateClusterAndHost.

func (*MockClusterManagerMockRecorder) AddOrUpdatePrimaryCluster added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) AddOrUpdatePrimaryCluster(cluster interface{}) *gomock.Call

AddOrUpdatePrimaryCluster indicates an expected call of AddOrUpdatePrimaryCluster.

func (*MockClusterManagerMockRecorder) AppendClusterHosts added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) AppendClusterHosts(clusterName, hostConfigs interface{}) *gomock.Call

AppendClusterHosts indicates an expected call of AppendClusterHosts.

func (*MockClusterManagerMockRecorder) ClusterExist added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) ClusterExist(clusterName interface{}) *gomock.Call

ClusterExist indicates an expected call of ClusterExist.

func (*MockClusterManagerMockRecorder) ConnPoolForCluster added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) ConnPoolForCluster(balancerContext, snapshot, protocol interface{}) *gomock.Call

ConnPoolForCluster indicates an expected call of ConnPoolForCluster.

func (*MockClusterManagerMockRecorder) Destroy added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) Destroy() *gomock.Call

Destroy indicates an expected call of Destroy.

func (*MockClusterManagerMockRecorder) GetClusterSnapshot added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) GetClusterSnapshot(context, cluster interface{}) *gomock.Call

GetClusterSnapshot indicates an expected call of GetClusterSnapshot.

func (*MockClusterManagerMockRecorder) GetTLSManager added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) GetTLSManager() *gomock.Call

GetTLSManager indicates an expected call of GetTLSManager.

func (*MockClusterManagerMockRecorder) PutClusterSnapshot added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) PutClusterSnapshot(arg0 interface{}) *gomock.Call

PutClusterSnapshot indicates an expected call of PutClusterSnapshot.

func (*MockClusterManagerMockRecorder) RemoveClusterHosts added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) RemoveClusterHosts(clusterName, hosts interface{}) *gomock.Call

RemoveClusterHosts indicates an expected call of RemoveClusterHosts.

func (*MockClusterManagerMockRecorder) RemovePrimaryCluster added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) RemovePrimaryCluster(clusters ...interface{}) *gomock.Call

RemovePrimaryCluster indicates an expected call of RemovePrimaryCluster.

func (*MockClusterManagerMockRecorder) ShutdownConnectionPool added in v0.23.0 

func (mr *MockClusterManagerMockRecorder) ShutdownConnectionPool(proto, addr interface{}) *gomock.Call

ShutdownConnectionPool indicates an expected call of ShutdownConnectionPool.

func (*MockClusterManagerMockRecorder) TCPConnForCluster added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) TCPConnForCluster(balancerContext, snapshot interface{}) *gomock.Call

TCPConnForCluster indicates an expected call of TCPConnForCluster.

func (*MockClusterManagerMockRecorder) UDPConnForCluster added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) UDPConnForCluster(balancerContext, snapshot interface{}) *gomock.Call

UDPConnForCluster indicates an expected call of UDPConnForCluster.

func (*MockClusterManagerMockRecorder) UpdateCluster added in v1.1.0 

func (mr *MockClusterManagerMockRecorder) UpdateCluster(cluster, clusterHandler interface{}) *gomock.Call

UpdateCluster indicates an expected call of UpdateCluster.

func (*MockClusterManagerMockRecorder) UpdateClusterHosts added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) UpdateClusterHosts(cluster, hosts interface{}) *gomock.Call

UpdateClusterHosts indicates an expected call of UpdateClusterHosts.

func (*MockClusterManagerMockRecorder) UpdateHosts added in v1.1.0 

func (mr *MockClusterManagerMockRecorder) UpdateHosts(clusterName, hostConfigs, hostHandler interface{}) *gomock.Call

UpdateHosts indicates an expected call of UpdateHosts.

func (*MockClusterManagerMockRecorder) UpdateTLSManager added in v0.17.0 

func (mr *MockClusterManagerMockRecorder) UpdateTLSManager(arg0 interface{}) *gomock.Call

UpdateTLSManager indicates an expected call of UpdateTLSManager.

type MockClusterMockRecorder added in v0.17.0 

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

MockClusterMockRecorder is the mock recorder for MockCluster.

func (*MockClusterMockRecorder) AddHealthCheckCallbacks added in v0.17.0 

func (mr *MockClusterMockRecorder) AddHealthCheckCallbacks(cb interface{}) *gomock.Call

AddHealthCheckCallbacks indicates an expected call of AddHealthCheckCallbacks.

func (*MockClusterMockRecorder) Snapshot added in v0.17.0 

func (mr *MockClusterMockRecorder) Snapshot() *gomock.Call

Snapshot indicates an expected call of Snapshot.

func (*MockClusterMockRecorder) StopHealthChecking added in v0.17.0 

func (mr *MockClusterMockRecorder) StopHealthChecking() *gomock.Call

StopHealthChecking indicates an expected call of StopHealthChecking.

func (*MockClusterMockRecorder) UpdateHosts added in v0.17.0 

func (mr *MockClusterMockRecorder) UpdateHosts(arg0 interface{}) *gomock.Call

UpdateHosts indicates an expected call of UpdateHosts.

type MockClusterSnapshot added in v0.17.0 

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

MockClusterSnapshot is a mock of ClusterSnapshot interface.

func NewMockClusterSnapshot added in v0.17.0 

func NewMockClusterSnapshot(ctrl *gomock.Controller) *MockClusterSnapshot

NewMockClusterSnapshot creates a new mock instance.

func (*MockClusterSnapshot) ClusterInfo added in v0.17.0 

func (m *MockClusterSnapshot) ClusterInfo() types.ClusterInfo

ClusterInfo mocks base method.

func (*MockClusterSnapshot) EXPECT added in v0.17.0 

func (m *MockClusterSnapshot) EXPECT() *MockClusterSnapshotMockRecorder

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

func (*MockClusterSnapshot) HostNum added in v0.17.0 

func (m *MockClusterSnapshot) HostNum(metadata api.MetadataMatchCriteria) int

HostNum mocks base method.

func (*MockClusterSnapshot) HostSet added in v0.17.0 

func (m *MockClusterSnapshot) HostSet() types.HostSet

HostSet mocks base method.

func (*MockClusterSnapshot) IsExistsHosts added in v0.17.0 

func (m *MockClusterSnapshot) IsExistsHosts(metadata api.MetadataMatchCriteria) bool

IsExistsHosts mocks base method.

func (*MockClusterSnapshot) LoadBalancer added in v0.17.0 

func (m *MockClusterSnapshot) LoadBalancer() types.LoadBalancer

LoadBalancer mocks base method.

type MockClusterSnapshotMockRecorder added in v0.17.0 

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

MockClusterSnapshotMockRecorder is the mock recorder for MockClusterSnapshot.

func (*MockClusterSnapshotMockRecorder) ClusterInfo added in v0.17.0 

func (mr *MockClusterSnapshotMockRecorder) ClusterInfo() *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockClusterSnapshotMockRecorder) HostNum added in v0.17.0 

func (mr *MockClusterSnapshotMockRecorder) HostNum(metadata interface{}) *gomock.Call

HostNum indicates an expected call of HostNum.

func (*MockClusterSnapshotMockRecorder) HostSet added in v0.17.0 

func (mr *MockClusterSnapshotMockRecorder) HostSet() *gomock.Call

HostSet indicates an expected call of HostSet.

func (*MockClusterSnapshotMockRecorder) IsExistsHosts added in v0.17.0 

func (mr *MockClusterSnapshotMockRecorder) IsExistsHosts(metadata interface{}) *gomock.Call

IsExistsHosts indicates an expected call of IsExistsHosts.

func (*MockClusterSnapshotMockRecorder) LoadBalancer added in v0.17.0 

func (mr *MockClusterSnapshotMockRecorder) LoadBalancer() *gomock.Call

LoadBalancer indicates an expected call of LoadBalancer.

type MockConfigHooks added in v0.27.0 

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

MockConfigHooks is a mock of ConfigHooks interface.

func NewMockConfigHooks added in v0.27.0 

func NewMockConfigHooks(ctrl *gomock.Controller) *MockConfigHooks

NewMockConfigHooks creates a new mock instance.

func (*MockConfigHooks) ClientHandshakeVerify added in v0.27.0 

func (m *MockConfigHooks) ClientHandshakeVerify(cfg *tls.Config) func([][]byte, [][]*x509.Certificate) error

ClientHandshakeVerify mocks base method.

func (*MockConfigHooks) EXPECT added in v0.27.0 

func (m *MockConfigHooks) EXPECT() *MockConfigHooksMockRecorder

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

func (*MockConfigHooks) GenerateHashValue added in v0.27.0 

func (m *MockConfigHooks) GenerateHashValue(cfg *tls.Config) *types.HashValue

GenerateHashValue mocks base method.

func (*MockConfigHooks) GetCertificate added in v0.27.0 

func (m *MockConfigHooks) GetCertificate(certIndex, keyIndex string) (tls.Certificate, error)

GetCertificate mocks base method.

func (*MockConfigHooks) GetClientAuth added in v0.27.0 

func (m *MockConfigHooks) GetClientAuth(cfg *v2.TLSConfig) tls.ClientAuthType

GetClientAuth mocks base method.

func (*MockConfigHooks) GetX509Pool added in v0.27.0 

func (m *MockConfigHooks) GetX509Pool(caIndex string) (*x509.CertPool, error)

GetX509Pool mocks base method.

func (*MockConfigHooks) ServerHandshakeVerify added in v0.27.0 

func (m *MockConfigHooks) ServerHandshakeVerify(cfg *tls.Config) func([][]byte, [][]*x509.Certificate) error

ServerHandshakeVerify mocks base method.

type MockConfigHooksFactory added in v0.27.0 

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

MockConfigHooksFactory is a mock of ConfigHooksFactory interface.

func NewMockConfigHooksFactory added in v0.27.0 

func NewMockConfigHooksFactory(ctrl *gomock.Controller) *MockConfigHooksFactory

NewMockConfigHooksFactory creates a new mock instance.

func (*MockConfigHooksFactory) CreateConfigHooks added in v0.27.0 

func (m *MockConfigHooksFactory) CreateConfigHooks(config map[string]interface{}) mtls.ConfigHooks

CreateConfigHooks mocks base method.

func (*MockConfigHooksFactory) EXPECT added in v0.27.0 

func (m *MockConfigHooksFactory) EXPECT() *MockConfigHooksFactoryMockRecorder

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

type MockConfigHooksFactoryMockRecorder added in v0.27.0 

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

MockConfigHooksFactoryMockRecorder is the mock recorder for MockConfigHooksFactory.

func (*MockConfigHooksFactoryMockRecorder) CreateConfigHooks added in v0.27.0 

func (mr *MockConfigHooksFactoryMockRecorder) CreateConfigHooks(config interface{}) *gomock.Call

CreateConfigHooks indicates an expected call of CreateConfigHooks.

type MockConfigHooksMockRecorder added in v0.27.0 

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

MockConfigHooksMockRecorder is the mock recorder for MockConfigHooks.

func (*MockConfigHooksMockRecorder) ClientHandshakeVerify added in v0.27.0 

func (mr *MockConfigHooksMockRecorder) ClientHandshakeVerify(cfg interface{}) *gomock.Call

ClientHandshakeVerify indicates an expected call of ClientHandshakeVerify.

func (*MockConfigHooksMockRecorder) GenerateHashValue added in v0.27.0 

func (mr *MockConfigHooksMockRecorder) GenerateHashValue(cfg interface{}) *gomock.Call

GenerateHashValue indicates an expected call of GenerateHashValue.

func (*MockConfigHooksMockRecorder) GetCertificate added in v0.27.0 

func (mr *MockConfigHooksMockRecorder) GetCertificate(certIndex, keyIndex interface{}) *gomock.Call

GetCertificate indicates an expected call of GetCertificate.

func (*MockConfigHooksMockRecorder) GetClientAuth added in v0.27.0 

func (mr *MockConfigHooksMockRecorder) GetClientAuth(cfg interface{}) *gomock.Call

GetClientAuth indicates an expected call of GetClientAuth.

func (*MockConfigHooksMockRecorder) GetX509Pool added in v0.27.0 

func (mr *MockConfigHooksMockRecorder) GetX509Pool(caIndex interface{}) *gomock.Call

GetX509Pool indicates an expected call of GetX509Pool.

func (*MockConfigHooksMockRecorder) ServerHandshakeVerify added in v0.27.0 

func (mr *MockConfigHooksMockRecorder) ServerHandshakeVerify(cfg interface{}) *gomock.Call

ServerHandshakeVerify indicates an expected call of ServerHandshakeVerify.

type MockConnection 

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

MockConnection is a mock of Connection interface.

func NewMockConnection 

func NewMockConnection(ctrl *gomock.Controller) *MockConnection

NewMockConnection creates a new mock instance.

func (*MockConnection) AddBytesReadListener 

func (m *MockConnection) AddBytesReadListener(listener func(uint64))

AddBytesReadListener mocks base method.

func (*MockConnection) AddBytesSentListener 

func (m *MockConnection) AddBytesSentListener(listener func(uint64))

AddBytesSentListener mocks base method.

func (*MockConnection) AddConnectionEventListener 

func (m *MockConnection) AddConnectionEventListener(listener api.ConnectionEventListener)

AddConnectionEventListener mocks base method.

func (*MockConnection) BufferLimit 

func (m *MockConnection) BufferLimit() uint32

BufferLimit mocks base method.

func (*MockConnection) Close 

func (m *MockConnection) Close(ccType api.ConnectionCloseType, eventType api.ConnectionEvent) error

Close mocks base method.

func (*MockConnection) EXPECT 

func (m *MockConnection) EXPECT() *MockConnectionMockRecorder

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

func (*MockConnection) FilterManager 

func (m *MockConnection) FilterManager() api.FilterManager

FilterManager mocks base method.

func (*MockConnection) GetReadBuffer 

func (m *MockConnection) GetReadBuffer() api.IoBuffer

GetReadBuffer mocks base method.

func (*MockConnection) GetWriteBuffer 

func (m *MockConnection) GetWriteBuffer() []api.IoBuffer

GetWriteBuffer mocks base method.

func (*MockConnection) ID 

func (m *MockConnection) ID() uint64

ID mocks base method.

func (*MockConnection) LocalAddr 

func (m *MockConnection) LocalAddr() net.Addr

LocalAddr mocks base method.

func (*MockConnection) LocalAddressRestored 

func (m *MockConnection) LocalAddressRestored() bool

LocalAddressRestored mocks base method.

func (*MockConnection) NextProtocol 

func (m *MockConnection) NextProtocol() string

NextProtocol mocks base method.

func (*MockConnection) OnConnectionEvent added in v0.24.0 

func (m *MockConnection) OnConnectionEvent(event api.ConnectionEvent)

OnConnectionEvent mocks base method.

func (*MockConnection) OnRead 

func (m *MockConnection) OnRead(buffer api.IoBuffer)

OnRead mocks base method.

func (*MockConnection) RawConn 

func (m *MockConnection) RawConn() net.Conn

RawConn mocks base method.

func (*MockConnection) ReadEnabled 

func (m *MockConnection) ReadEnabled() bool

ReadEnabled mocks base method.

func (*MockConnection) RemoteAddr 

func (m *MockConnection) RemoteAddr() net.Addr

RemoteAddr mocks base method.

func (*MockConnection) SetBufferLimit 

func (m *MockConnection) SetBufferLimit(limit uint32)

SetBufferLimit mocks base method.

func (*MockConnection) SetCollector 

func (m *MockConnection) SetCollector(read, write metrics.Counter)

SetCollector mocks base method.

func (*MockConnection) SetIdleTimeout 

func (m *MockConnection) SetIdleTimeout(readTimeout, idleTimeout time.Duration)

SetIdleTimeout mocks base method.

func (*MockConnection) SetLocalAddress 

func (m *MockConnection) SetLocalAddress(localAddress net.Addr, restored bool)

SetLocalAddress mocks base method.

func (*MockConnection) SetNoDelay 

func (m *MockConnection) SetNoDelay(enable bool)

SetNoDelay mocks base method.

func (*MockConnection) SetReadDisable 

func (m *MockConnection) SetReadDisable(disable bool)

SetReadDisable mocks base method.

func (*MockConnection) SetRemoteAddr 

func (m *MockConnection) SetRemoteAddr(address net.Addr)

SetRemoteAddr mocks base method.

func (*MockConnection) SetTransferEventListener 

func (m *MockConnection) SetTransferEventListener(listener func() bool)

SetTransferEventListener mocks base method.

func (*MockConnection) Start 

func (m *MockConnection) Start(lctx context.Context)

Start mocks base method.

func (*MockConnection) State 

func (m *MockConnection) State() api.ConnState

State mocks base method.

func (*MockConnection) TLS 

func (m *MockConnection) TLS() net.Conn

TLS mocks base method.

func (*MockConnection) Write 

func (m *MockConnection) Write(buf ...api.IoBuffer) error

Write mocks base method.

type MockConnectionEventListener 

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

MockConnectionEventListener is a mock of ConnectionEventListener interface.

func NewMockConnectionEventListener 

func NewMockConnectionEventListener(ctrl *gomock.Controller) *MockConnectionEventListener

NewMockConnectionEventListener creates a new mock instance.

func (*MockConnectionEventListener) EXPECT 

func (m *MockConnectionEventListener) EXPECT() *MockConnectionEventListenerMockRecorder

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

func (*MockConnectionEventListener) OnEvent 

func (m *MockConnectionEventListener) OnEvent(event api.ConnectionEvent)

OnEvent mocks base method.

type MockConnectionEventListenerMockRecorder 

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

MockConnectionEventListenerMockRecorder is the mock recorder for MockConnectionEventListener.

func (*MockConnectionEventListenerMockRecorder) OnEvent 

func (mr *MockConnectionEventListenerMockRecorder) OnEvent(event interface{}) *gomock.Call

OnEvent indicates an expected call of OnEvent.

type MockConnectionMockRecorder 

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

MockConnectionMockRecorder is the mock recorder for MockConnection.

func (*MockConnectionMockRecorder) AddBytesReadListener 

func (mr *MockConnectionMockRecorder) AddBytesReadListener(listener interface{}) *gomock.Call

AddBytesReadListener indicates an expected call of AddBytesReadListener.

func (*MockConnectionMockRecorder) AddBytesSentListener 

func (mr *MockConnectionMockRecorder) AddBytesSentListener(listener interface{}) *gomock.Call

AddBytesSentListener indicates an expected call of AddBytesSentListener.

func (*MockConnectionMockRecorder) AddConnectionEventListener 

func (mr *MockConnectionMockRecorder) AddConnectionEventListener(listener interface{}) *gomock.Call

AddConnectionEventListener indicates an expected call of AddConnectionEventListener.

func (*MockConnectionMockRecorder) BufferLimit 

func (mr *MockConnectionMockRecorder) BufferLimit() *gomock.Call

BufferLimit indicates an expected call of BufferLimit.

func (*MockConnectionMockRecorder) Close 

func (mr *MockConnectionMockRecorder) Close(ccType, eventType interface{}) *gomock.Call

Close indicates an expected call of Close.

func (*MockConnectionMockRecorder) FilterManager 

func (mr *MockConnectionMockRecorder) FilterManager() *gomock.Call

FilterManager indicates an expected call of FilterManager.

func (*MockConnectionMockRecorder) GetReadBuffer 

func (mr *MockConnectionMockRecorder) GetReadBuffer() *gomock.Call

GetReadBuffer indicates an expected call of GetReadBuffer.

func (*MockConnectionMockRecorder) GetWriteBuffer 

func (mr *MockConnectionMockRecorder) GetWriteBuffer() *gomock.Call

GetWriteBuffer indicates an expected call of GetWriteBuffer.

func (*MockConnectionMockRecorder) ID 

func (mr *MockConnectionMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockConnectionMockRecorder) LocalAddr 

func (mr *MockConnectionMockRecorder) LocalAddr() *gomock.Call

LocalAddr indicates an expected call of LocalAddr.

func (*MockConnectionMockRecorder) LocalAddressRestored 

func (mr *MockConnectionMockRecorder) LocalAddressRestored() *gomock.Call

LocalAddressRestored indicates an expected call of LocalAddressRestored.

func (*MockConnectionMockRecorder) NextProtocol 

func (mr *MockConnectionMockRecorder) NextProtocol() *gomock.Call

NextProtocol indicates an expected call of NextProtocol.

func (*MockConnectionMockRecorder) OnConnectionEvent added in v0.24.0 

func (mr *MockConnectionMockRecorder) OnConnectionEvent(event interface{}) *gomock.Call

OnConnectionEvent indicates an expected call of OnConnectionEvent.

func (*MockConnectionMockRecorder) OnRead 

func (mr *MockConnectionMockRecorder) OnRead(buffer interface{}) *gomock.Call

OnRead indicates an expected call of OnRead.

func (*MockConnectionMockRecorder) RawConn 

func (mr *MockConnectionMockRecorder) RawConn() *gomock.Call

RawConn indicates an expected call of RawConn.

func (*MockConnectionMockRecorder) ReadEnabled 

func (mr *MockConnectionMockRecorder) ReadEnabled() *gomock.Call

ReadEnabled indicates an expected call of ReadEnabled.

func (*MockConnectionMockRecorder) RemoteAddr 

func (mr *MockConnectionMockRecorder) RemoteAddr() *gomock.Call

RemoteAddr indicates an expected call of RemoteAddr.

func (*MockConnectionMockRecorder) SetBufferLimit 

func (mr *MockConnectionMockRecorder) SetBufferLimit(limit interface{}) *gomock.Call

SetBufferLimit indicates an expected call of SetBufferLimit.

func (*MockConnectionMockRecorder) SetCollector 

func (mr *MockConnectionMockRecorder) SetCollector(read, write interface{}) *gomock.Call

SetCollector indicates an expected call of SetCollector.

func (*MockConnectionMockRecorder) SetIdleTimeout 

func (mr *MockConnectionMockRecorder) SetIdleTimeout(readTimeout, idleTimeout interface{}) *gomock.Call

SetIdleTimeout indicates an expected call of SetIdleTimeout.

func (*MockConnectionMockRecorder) SetLocalAddress 

func (mr *MockConnectionMockRecorder) SetLocalAddress(localAddress, restored interface{}) *gomock.Call

SetLocalAddress indicates an expected call of SetLocalAddress.

func (*MockConnectionMockRecorder) SetNoDelay 

func (mr *MockConnectionMockRecorder) SetNoDelay(enable interface{}) *gomock.Call

SetNoDelay indicates an expected call of SetNoDelay.

func (*MockConnectionMockRecorder) SetReadDisable 

func (mr *MockConnectionMockRecorder) SetReadDisable(disable interface{}) *gomock.Call

SetReadDisable indicates an expected call of SetReadDisable.

func (*MockConnectionMockRecorder) SetRemoteAddr 

func (mr *MockConnectionMockRecorder) SetRemoteAddr(address interface{}) *gomock.Call

SetRemoteAddr indicates an expected call of SetRemoteAddr.

func (*MockConnectionMockRecorder) SetTransferEventListener 

func (mr *MockConnectionMockRecorder) SetTransferEventListener(listener interface{}) *gomock.Call

SetTransferEventListener indicates an expected call of SetTransferEventListener.

func (*MockConnectionMockRecorder) Start 

func (mr *MockConnectionMockRecorder) Start(lctx interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockConnectionMockRecorder) State 

func (mr *MockConnectionMockRecorder) State() *gomock.Call

State indicates an expected call of State.

func (*MockConnectionMockRecorder) TLS 

func (mr *MockConnectionMockRecorder) TLS() *gomock.Call

TLS indicates an expected call of TLS.

func (*MockConnectionMockRecorder) Write 

func (mr *MockConnectionMockRecorder) Write(buf ...interface{}) *gomock.Call

Write indicates an expected call of Write.

type MockConnectionPool 

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

MockConnectionPool is a mock of ConnectionPool interface.

func NewMockConnectionPool 

func NewMockConnectionPool(ctrl *gomock.Controller) *MockConnectionPool

NewMockConnectionPool creates a new mock instance.

func (*MockConnectionPool) CheckAndInit 

func (m *MockConnectionPool) CheckAndInit(ctx context.Context) bool

CheckAndInit mocks base method.

func (*MockConnectionPool) Close 

func (m *MockConnectionPool) Close()

Close mocks base method.

func (*MockConnectionPool) EXPECT 

func (m *MockConnectionPool) EXPECT() *MockConnectionPoolMockRecorder

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

func (*MockConnectionPool) Host 

func (m *MockConnectionPool) Host() types.Host

Host mocks base method.

func (*MockConnectionPool) NewStream 

func (m *MockConnectionPool) NewStream(ctx context.Context, receiver types.StreamReceiveListener) (types.Host, types.StreamSender, types.PoolFailureReason)

NewStream mocks base method.

func (*MockConnectionPool) Protocol 

func (m *MockConnectionPool) Protocol() api.ProtocolName

Protocol mocks base method.

func (*MockConnectionPool) Shutdown 

func (m *MockConnectionPool) Shutdown()

Shutdown mocks base method.

func (*MockConnectionPool) TLSHashValue 

func (m *MockConnectionPool) TLSHashValue() *types.HashValue

TLSHashValue mocks base method.

type MockConnectionPoolMockRecorder 

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

MockConnectionPoolMockRecorder is the mock recorder for MockConnectionPool.

func (*MockConnectionPoolMockRecorder) CheckAndInit 

func (mr *MockConnectionPoolMockRecorder) CheckAndInit(ctx interface{}) *gomock.Call

CheckAndInit indicates an expected call of CheckAndInit.

func (*MockConnectionPoolMockRecorder) Close 

func (mr *MockConnectionPoolMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockConnectionPoolMockRecorder) Host 

func (mr *MockConnectionPoolMockRecorder) Host() *gomock.Call

Host indicates an expected call of Host.

func (*MockConnectionPoolMockRecorder) NewStream 

func (mr *MockConnectionPoolMockRecorder) NewStream(ctx, receiver interface{}) *gomock.Call

NewStream indicates an expected call of NewStream.

func (*MockConnectionPoolMockRecorder) Protocol 

func (mr *MockConnectionPoolMockRecorder) Protocol() *gomock.Call

Protocol indicates an expected call of Protocol.

func (*MockConnectionPoolMockRecorder) Shutdown 

func (mr *MockConnectionPoolMockRecorder) Shutdown() *gomock.Call

Shutdown indicates an expected call of Shutdown.

func (*MockConnectionPoolMockRecorder) TLSHashValue 

func (mr *MockConnectionPoolMockRecorder) TLSHashValue() *gomock.Call

TLSHashValue indicates an expected call of TLSHashValue.

type MockDirectResponseRule added in v0.17.0 

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

MockDirectResponseRule is a mock of DirectResponseRule interface.

func NewMockDirectResponseRule added in v0.17.0 

func NewMockDirectResponseRule(ctrl *gomock.Controller) *MockDirectResponseRule

NewMockDirectResponseRule creates a new mock instance.

func (*MockDirectResponseRule) Body added in v0.17.0 

func (m *MockDirectResponseRule) Body() string

Body mocks base method.

func (*MockDirectResponseRule) EXPECT added in v0.17.0 

func (m *MockDirectResponseRule) EXPECT() *MockDirectResponseRuleMockRecorder

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

func (*MockDirectResponseRule) StatusCode added in v0.17.0 

func (m *MockDirectResponseRule) StatusCode() int

StatusCode mocks base method.

type MockDirectResponseRuleMockRecorder added in v0.17.0 

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

MockDirectResponseRuleMockRecorder is the mock recorder for MockDirectResponseRule.

func (*MockDirectResponseRuleMockRecorder) Body added in v0.17.0 

func (mr *MockDirectResponseRuleMockRecorder) Body() *gomock.Call

Body indicates an expected call of Body.

func (*MockDirectResponseRuleMockRecorder) StatusCode added in v0.17.0 

func (mr *MockDirectResponseRuleMockRecorder) StatusCode() *gomock.Call

StatusCode indicates an expected call of StatusCode.

type MockDriver 

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

MockDriver is a mock of Driver interface.

func NewMockDriver 

func NewMockDriver(ctrl *gomock.Controller) *MockDriver

NewMockDriver creates a new mock instance.

func (*MockDriver) EXPECT 

func (m *MockDriver) EXPECT() *MockDriverMockRecorder

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

func (*MockDriver) Get 

func (m *MockDriver) Get(proto api.ProtocolName) api.Tracer

Get mocks base method.

func (*MockDriver) Init 

func (m *MockDriver) Init(config map[string]interface{}) error

Init mocks base method.

func (*MockDriver) Register 

func (m *MockDriver) Register(proto api.ProtocolName, builder api.TracerBuilder)

Register mocks base method.

type MockDriverMockRecorder 

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

MockDriverMockRecorder is the mock recorder for MockDriver.

func (*MockDriverMockRecorder) Get 

func (mr *MockDriverMockRecorder) Get(proto interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockDriverMockRecorder) Init 

func (mr *MockDriverMockRecorder) Init(config interface{}) *gomock.Call

Init indicates an expected call of Init.

func (*MockDriverMockRecorder) Register 

func (mr *MockDriverMockRecorder) Register(proto, builder interface{}) *gomock.Call

Register indicates an expected call of Register.

type MockFactoryInitializer added in v0.27.0 

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

MockFactoryInitializer is a mock of FactoryInitializer interface.

func NewMockFactoryInitializer added in v0.27.0 

func NewMockFactoryInitializer(ctrl *gomock.Controller) *MockFactoryInitializer

NewMockFactoryInitializer creates a new mock instance.

func (*MockFactoryInitializer) EXPECT added in v0.27.0 

func (m *MockFactoryInitializer) EXPECT() *MockFactoryInitializerMockRecorder

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

func (*MockFactoryInitializer) Init added in v0.27.0 

func (m *MockFactoryInitializer) Init(arg0 interface{}) error

Init mocks base method.

type MockFactoryInitializerMockRecorder added in v0.27.0 

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

MockFactoryInitializerMockRecorder is the mock recorder for MockFactoryInitializer.

func (*MockFactoryInitializerMockRecorder) Init added in v0.27.0 

func (mr *MockFactoryInitializerMockRecorder) Init(arg0 interface{}) *gomock.Call

Init indicates an expected call of Init.

type MockFilterManager 

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

MockFilterManager is a mock of FilterManager interface.

func NewMockFilterManager 

func NewMockFilterManager(ctrl *gomock.Controller) *MockFilterManager

NewMockFilterManager creates a new mock instance.

func (*MockFilterManager) AddReadFilter 

func (m *MockFilterManager) AddReadFilter(rf api.ReadFilter)

AddReadFilter mocks base method.

func (*MockFilterManager) AddWriteFilter 

func (m *MockFilterManager) AddWriteFilter(wf api.WriteFilter)

AddWriteFilter mocks base method.

func (*MockFilterManager) EXPECT 

func (m *MockFilterManager) EXPECT() *MockFilterManagerMockRecorder

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

func (*MockFilterManager) InitializeReadFilters 

func (m *MockFilterManager) InitializeReadFilters() bool

InitializeReadFilters mocks base method.

func (*MockFilterManager) ListReadFilter 

func (m *MockFilterManager) ListReadFilter() []api.ReadFilter

ListReadFilter mocks base method.

func (*MockFilterManager) ListWriteFilters 

func (m *MockFilterManager) ListWriteFilters() []api.WriteFilter

ListWriteFilters mocks base method.

func (*MockFilterManager) OnRead 

func (m *MockFilterManager) OnRead()

OnRead mocks base method.

func (*MockFilterManager) OnWrite 

func (m *MockFilterManager) OnWrite(buffer []api.IoBuffer) api.FilterStatus

OnWrite mocks base method.

type MockFilterManagerMockRecorder 

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

MockFilterManagerMockRecorder is the mock recorder for MockFilterManager.

func (*MockFilterManagerMockRecorder) AddReadFilter 

func (mr *MockFilterManagerMockRecorder) AddReadFilter(rf interface{}) *gomock.Call

AddReadFilter indicates an expected call of AddReadFilter.

func (*MockFilterManagerMockRecorder) AddWriteFilter 

func (mr *MockFilterManagerMockRecorder) AddWriteFilter(wf interface{}) *gomock.Call

AddWriteFilter indicates an expected call of AddWriteFilter.

func (*MockFilterManagerMockRecorder) InitializeReadFilters 

func (mr *MockFilterManagerMockRecorder) InitializeReadFilters() *gomock.Call

InitializeReadFilters indicates an expected call of InitializeReadFilters.

func (*MockFilterManagerMockRecorder) ListReadFilter 

func (mr *MockFilterManagerMockRecorder) ListReadFilter() *gomock.Call

ListReadFilter indicates an expected call of ListReadFilter.

func (*MockFilterManagerMockRecorder) ListWriteFilters 

func (mr *MockFilterManagerMockRecorder) ListWriteFilters() *gomock.Call

ListWriteFilters indicates an expected call of ListWriteFilters.

func (*MockFilterManagerMockRecorder) OnRead 

func (mr *MockFilterManagerMockRecorder) OnRead() *gomock.Call

OnRead indicates an expected call of OnRead.

func (*MockFilterManagerMockRecorder) OnWrite 

func (mr *MockFilterManagerMockRecorder) OnWrite(buffer interface{}) *gomock.Call

OnWrite indicates an expected call of OnWrite.

type MockHashPolicy added in v0.17.0 

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

MockHashPolicy is a mock of HashPolicy interface.

func NewMockHashPolicy added in v0.17.0 

func NewMockHashPolicy(ctrl *gomock.Controller) *MockHashPolicy

NewMockHashPolicy creates a new mock instance.

func (*MockHashPolicy) EXPECT added in v0.17.0 

func (m *MockHashPolicy) EXPECT() *MockHashPolicyMockRecorder

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

func (*MockHashPolicy) GenerateHash added in v0.17.0 

func (m *MockHashPolicy) GenerateHash(context context.Context) uint64

GenerateHash mocks base method.

type MockHashPolicyMockRecorder added in v0.17.0 

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

MockHashPolicyMockRecorder is the mock recorder for MockHashPolicy.

func (*MockHashPolicyMockRecorder) GenerateHash added in v0.17.0 

func (mr *MockHashPolicyMockRecorder) GenerateHash(context interface{}) *gomock.Call

GenerateHash indicates an expected call of GenerateHash.

type MockHeaderFormat 

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

MockHeaderFormat is a mock of HeaderFormat interface.

func NewMockHeaderFormat 

func NewMockHeaderFormat(ctrl *gomock.Controller) *MockHeaderFormat

NewMockHeaderFormat creates a new mock instance.

func (*MockHeaderFormat) Append 

func (m *MockHeaderFormat) Append() bool

Append mocks base method.

func (*MockHeaderFormat) EXPECT 

func (m *MockHeaderFormat) EXPECT() *MockHeaderFormatMockRecorder

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

func (*MockHeaderFormat) Format 

func (m *MockHeaderFormat) Format(info api.RequestInfo) string

Format mocks base method.

type MockHeaderFormatMockRecorder 

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

MockHeaderFormatMockRecorder is the mock recorder for MockHeaderFormat.

func (*MockHeaderFormatMockRecorder) Append 

func (mr *MockHeaderFormatMockRecorder) Append() *gomock.Call

Append indicates an expected call of Append.

func (*MockHeaderFormatMockRecorder) Format 

func (mr *MockHeaderFormatMockRecorder) Format(info interface{}) *gomock.Call

Format indicates an expected call of Format.

type MockHeaderMap added in v0.17.0 

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

MockHeaderMap is a mock of HeaderMap interface.

func NewMockHeaderMap added in v0.17.0 

func NewMockHeaderMap(ctrl *gomock.Controller) *MockHeaderMap

NewMockHeaderMap creates a new mock instance.

func (*MockHeaderMap) Add added in v0.17.0 

func (m *MockHeaderMap) Add(key, value string)

Add mocks base method.

func (*MockHeaderMap) ByteSize added in v0.17.0 

func (m *MockHeaderMap) ByteSize() uint64

ByteSize mocks base method.

func (*MockHeaderMap) Clone added in v0.17.0 

func (m *MockHeaderMap) Clone() api.HeaderMap

Clone mocks base method.

func (*MockHeaderMap) Del added in v0.17.0 

func (m *MockHeaderMap) Del(key string)

Del mocks base method.

func (*MockHeaderMap) EXPECT added in v0.17.0 

func (m *MockHeaderMap) EXPECT() *MockHeaderMapMockRecorder

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

func (*MockHeaderMap) Get added in v0.17.0 

func (m *MockHeaderMap) Get(key string) (string, bool)

Get mocks base method.

func (*MockHeaderMap) Range added in v0.17.0 

func (m *MockHeaderMap) Range(f func(string, string) bool)

Range mocks base method.

func (*MockHeaderMap) Set added in v0.17.0 

func (m *MockHeaderMap) Set(key, value string)

Set mocks base method.

type MockHeaderMapMockRecorder added in v0.17.0 

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

MockHeaderMapMockRecorder is the mock recorder for MockHeaderMap.

func (*MockHeaderMapMockRecorder) Add added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) Add(key, value interface{}) *gomock.Call

Add indicates an expected call of Add.

func (*MockHeaderMapMockRecorder) ByteSize added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) ByteSize() *gomock.Call

ByteSize indicates an expected call of ByteSize.

func (*MockHeaderMapMockRecorder) Clone added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) Clone() *gomock.Call

Clone indicates an expected call of Clone.

func (*MockHeaderMapMockRecorder) Del added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) Del(key interface{}) *gomock.Call

Del indicates an expected call of Del.

func (*MockHeaderMapMockRecorder) Get added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) Get(key interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockHeaderMapMockRecorder) Range added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) Range(f interface{}) *gomock.Call

Range indicates an expected call of Range.

func (*MockHeaderMapMockRecorder) Set added in v0.17.0 

func (mr *MockHeaderMapMockRecorder) Set(key, value interface{}) *gomock.Call

Set indicates an expected call of Set.

type MockHeaderMatcher added in v0.21.0 

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

MockHeaderMatcher is a mock of HeaderMatcher interface.

func NewMockHeaderMatcher added in v0.21.0 

func NewMockHeaderMatcher(ctrl *gomock.Controller) *MockHeaderMatcher

NewMockHeaderMatcher creates a new mock instance.

func (*MockHeaderMatcher) EXPECT added in v0.21.0 

func (m *MockHeaderMatcher) EXPECT() *MockHeaderMatcherMockRecorder

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

func (*MockHeaderMatcher) HeaderMatchCriteria added in v0.21.0 

func (m *MockHeaderMatcher) HeaderMatchCriteria() api.KeyValueMatchCriteria

HeaderMatchCriteria mocks base method.

func (*MockHeaderMatcher) Matches added in v0.21.0 

func (m *MockHeaderMatcher) Matches(ctx context.Context, requestHeaders api.HeaderMap) bool

Matches mocks base method.

type MockHeaderMatcherMockRecorder added in v0.21.0 

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

MockHeaderMatcherMockRecorder is the mock recorder for MockHeaderMatcher.

func (*MockHeaderMatcherMockRecorder) HeaderMatchCriteria added in v0.21.0 

func (mr *MockHeaderMatcherMockRecorder) HeaderMatchCriteria() *gomock.Call

HeaderMatchCriteria indicates an expected call of HeaderMatchCriteria.

func (*MockHeaderMatcherMockRecorder) Matches added in v0.21.0 

func (mr *MockHeaderMatcherMockRecorder) Matches(ctx, requestHeaders interface{}) *gomock.Call

Matches indicates an expected call of Matches.

type MockHost added in v0.17.0 

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

MockHost is a mock of Host interface.

func NewMockHost added in v0.17.0 

func NewMockHost(ctrl *gomock.Controller) *MockHost

NewMockHost creates a new mock instance.

func (*MockHost) Address added in v0.17.0 

func (m *MockHost) Address() net.Addr

Address mocks base method.

func (*MockHost) AddressString added in v0.17.0 

func (m *MockHost) AddressString() string

AddressString mocks base method.

func (*MockHost) ClearHealthFlag added in v0.17.0 

func (m *MockHost) ClearHealthFlag(flag api.HealthFlag)

ClearHealthFlag mocks base method.

func (*MockHost) ClusterInfo added in v0.17.0 

func (m *MockHost) ClusterInfo() types.ClusterInfo

ClusterInfo mocks base method.

func (*MockHost) Config added in v0.17.0 

func (m *MockHost) Config() v2.Host

Config mocks base method.

func (*MockHost) ContainHealthFlag added in v0.17.0 

func (m *MockHost) ContainHealthFlag(flag api.HealthFlag) bool

ContainHealthFlag mocks base method.

func (*MockHost) CreateConnection added in v0.17.0 

func (m *MockHost) CreateConnection(context context.Context) types.CreateConnectionData

CreateConnection mocks base method.

func (*MockHost) CreateUDPConnection added in v0.17.0 

func (m *MockHost) CreateUDPConnection(context context.Context) types.CreateConnectionData

CreateUDPConnection mocks base method.

func (*MockHost) EXPECT added in v0.17.0 

func (m *MockHost) EXPECT() *MockHostMockRecorder

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

func (*MockHost) Health added in v0.17.0 

func (m *MockHost) Health() bool

Health mocks base method.

func (*MockHost) HealthFlag added in v0.17.0 

func (m *MockHost) HealthFlag() api.HealthFlag

HealthFlag mocks base method.

func (*MockHost) HostStats added in v0.17.0 

func (m *MockHost) HostStats() *types.HostStats

HostStats mocks base method.

func (*MockHost) Hostname added in v0.17.0 

func (m *MockHost) Hostname() string

Hostname mocks base method.

func (*MockHost) LastHealthCheckPassTime added in v1.5.0 

func (m *MockHost) LastHealthCheckPassTime() time.Time

LastHealthCheckPassTime mocks base method.

func (*MockHost) Metadata added in v0.17.0 

func (m *MockHost) Metadata() api.Metadata

Metadata mocks base method.

func (*MockHost) SetClusterInfo added in v0.17.0 

func (m *MockHost) SetClusterInfo(info types.ClusterInfo)

SetClusterInfo mocks base method.

func (*MockHost) SetHealthFlag added in v0.17.0 

func (m *MockHost) SetHealthFlag(flag api.HealthFlag)

SetHealthFlag mocks base method.

func (*MockHost) SetLastHealthCheckPassTime added in v1.5.0 

func (m *MockHost) SetLastHealthCheckPassTime(lastHealthCheckPassTime time.Time)

SetLastHealthCheckPassTime mocks base method.

func (*MockHost) SupportTLS added in v0.17.0 

func (m *MockHost) SupportTLS() bool

SupportTLS mocks base method.

func (*MockHost) TLSHashValue added in v0.17.0 

func (m *MockHost) TLSHashValue() *types.HashValue

TLSHashValue mocks base method.

func (*MockHost) Weight added in v0.17.0 

func (m *MockHost) Weight() uint32

Weight mocks base method.

type MockHostMockRecorder added in v0.17.0 

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

MockHostMockRecorder is the mock recorder for MockHost.

func (*MockHostMockRecorder) Address added in v0.17.0 

func (mr *MockHostMockRecorder) Address() *gomock.Call

Address indicates an expected call of Address.

func (*MockHostMockRecorder) AddressString added in v0.17.0 

func (mr *MockHostMockRecorder) AddressString() *gomock.Call

AddressString indicates an expected call of AddressString.

func (*MockHostMockRecorder) ClearHealthFlag added in v0.17.0 

func (mr *MockHostMockRecorder) ClearHealthFlag(flag interface{}) *gomock.Call

ClearHealthFlag indicates an expected call of ClearHealthFlag.

func (*MockHostMockRecorder) ClusterInfo added in v0.17.0 

func (mr *MockHostMockRecorder) ClusterInfo() *gomock.Call

ClusterInfo indicates an expected call of ClusterInfo.

func (*MockHostMockRecorder) Config added in v0.17.0 

func (mr *MockHostMockRecorder) Config() *gomock.Call

Config indicates an expected call of Config.

func (*MockHostMockRecorder) ContainHealthFlag added in v0.17.0 

func (mr *MockHostMockRecorder) ContainHealthFlag(flag interface{}) *gomock.Call

ContainHealthFlag indicates an expected call of ContainHealthFlag.

func (*MockHostMockRecorder) CreateConnection added in v0.17.0 

func (mr *MockHostMockRecorder) CreateConnection(context interface{}) *gomock.Call

CreateConnection indicates an expected call of CreateConnection.

func (*MockHostMockRecorder) CreateUDPConnection added in v0.17.0 

func (mr *MockHostMockRecorder) CreateUDPConnection(context interface{}) *gomock.Call

CreateUDPConnection indicates an expected call of CreateUDPConnection.

func (*MockHostMockRecorder) Health added in v0.17.0 

func (mr *MockHostMockRecorder) Health() *gomock.Call

Health indicates an expected call of Health.

func (*MockHostMockRecorder) HealthFlag added in v0.17.0 

func (mr *MockHostMockRecorder) HealthFlag() *gomock.Call

HealthFlag indicates an expected call of HealthFlag.

func (*MockHostMockRecorder) HostStats added in v0.17.0 

func (mr *MockHostMockRecorder) HostStats() *gomock.Call

HostStats indicates an expected call of HostStats.

func (*MockHostMockRecorder) Hostname added in v0.17.0 

func (mr *MockHostMockRecorder) Hostname() *gomock.Call

Hostname indicates an expected call of Hostname.

func (*MockHostMockRecorder) LastHealthCheckPassTime added in v1.5.0 

func (mr *MockHostMockRecorder) LastHealthCheckPassTime() *gomock.Call

LastHealthCheckPassTime indicates an expected call of LastHealthCheckPassTime.

func (*MockHostMockRecorder) Metadata added in v0.17.0 

func (mr *MockHostMockRecorder) Metadata() *gomock.Call

Metadata indicates an expected call of Metadata.

func (*MockHostMockRecorder) SetClusterInfo added in v0.17.0 

func (mr *MockHostMockRecorder) SetClusterInfo(info interface{}) *gomock.Call

SetClusterInfo indicates an expected call of SetClusterInfo.

func (*MockHostMockRecorder) SetHealthFlag added in v0.17.0 

func (mr *MockHostMockRecorder) SetHealthFlag(flag interface{}) *gomock.Call

SetHealthFlag indicates an expected call of SetHealthFlag.

func (*MockHostMockRecorder) SetLastHealthCheckPassTime added in v1.5.0 

func (mr *MockHostMockRecorder) SetLastHealthCheckPassTime(lastHealthCheckPassTime interface{}) *gomock.Call

SetLastHealthCheckPassTime indicates an expected call of SetLastHealthCheckPassTime.

func (*MockHostMockRecorder) SupportTLS added in v0.17.0 

func (mr *MockHostMockRecorder) SupportTLS() *gomock.Call

SupportTLS indicates an expected call of SupportTLS.

func (*MockHostMockRecorder) TLSHashValue added in v0.17.0 

func (mr *MockHostMockRecorder) TLSHashValue() *gomock.Call

TLSHashValue indicates an expected call of TLSHashValue.

func (*MockHostMockRecorder) Weight added in v0.17.0 

func (mr *MockHostMockRecorder) Weight() *gomock.Call

Weight indicates an expected call of Weight.

type MockHostSet added in v0.17.0 

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

MockHostSet is a mock of HostSet interface.

func NewMockHostSet added in v0.17.0 

func NewMockHostSet(ctrl *gomock.Controller) *MockHostSet

NewMockHostSet creates a new mock instance.

func (*MockHostSet) EXPECT added in v0.17.0 

func (m *MockHostSet) EXPECT() *MockHostSetMockRecorder

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

func (*MockHostSet) Get added in v1.1.0 

func (m *MockHostSet) Get(i int) types.Host

Get mocks base method.

func (*MockHostSet) Range added in v1.1.0 

func (m *MockHostSet) Range(arg0 func(types.Host) bool)

Range mocks base method.

func (*MockHostSet) Size added in v1.1.0 

func (m *MockHostSet) Size() int

Size mocks base method.

type MockHostSetMockRecorder added in v0.17.0 

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

MockHostSetMockRecorder is the mock recorder for MockHostSet.

func (*MockHostSetMockRecorder) Get added in v1.1.0 

func (mr *MockHostSetMockRecorder) Get(i interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockHostSetMockRecorder) Range added in v1.1.0 

func (mr *MockHostSetMockRecorder) Range(arg0 interface{}) *gomock.Call

Range indicates an expected call of Range.

func (*MockHostSetMockRecorder) Size added in v1.1.0 

func (mr *MockHostSetMockRecorder) Size() *gomock.Call

Size indicates an expected call of Size.

type MockKeyValueMatchCriteria added in v0.21.0 

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

MockKeyValueMatchCriteria is a mock of KeyValueMatchCriteria interface.

func NewMockKeyValueMatchCriteria added in v0.21.0 

func NewMockKeyValueMatchCriteria(ctrl *gomock.Controller) *MockKeyValueMatchCriteria

NewMockKeyValueMatchCriteria creates a new mock instance.

func (*MockKeyValueMatchCriteria) EXPECT added in v0.21.0 

func (m *MockKeyValueMatchCriteria) EXPECT() *MockKeyValueMatchCriteriaMockRecorder

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

func (*MockKeyValueMatchCriteria) Get added in v0.21.0 

func (m *MockKeyValueMatchCriteria) Get(i int) api.KeyValueMatchCriterion

Get mocks base method.

func (*MockKeyValueMatchCriteria) Len added in v0.21.0 

func (m *MockKeyValueMatchCriteria) Len() int

Len mocks base method.

func (*MockKeyValueMatchCriteria) Range added in v0.21.0 

func (m *MockKeyValueMatchCriteria) Range(f func(api.KeyValueMatchCriterion) bool)

Range mocks base method.

type MockKeyValueMatchCriteriaMockRecorder added in v0.21.0 

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

MockKeyValueMatchCriteriaMockRecorder is the mock recorder for MockKeyValueMatchCriteria.

func (*MockKeyValueMatchCriteriaMockRecorder) Get added in v0.21.0 

func (mr *MockKeyValueMatchCriteriaMockRecorder) Get(i interface{}) *gomock.Call

Get indicates an expected call of Get.

func (*MockKeyValueMatchCriteriaMockRecorder) Len added in v0.21.0 

func (mr *MockKeyValueMatchCriteriaMockRecorder) Len() *gomock.Call

Len indicates an expected call of Len.

func (*MockKeyValueMatchCriteriaMockRecorder) Range added in v0.21.0 

func (mr *MockKeyValueMatchCriteriaMockRecorder) Range(f interface{}) *gomock.Call

Range indicates an expected call of Range.

type MockKeyValueMatchCriterion added in v0.21.0 

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

MockKeyValueMatchCriterion is a mock of KeyValueMatchCriterion interface.

func NewMockKeyValueMatchCriterion added in v0.21.0 

func NewMockKeyValueMatchCriterion(ctrl *gomock.Controller) *MockKeyValueMatchCriterion

NewMockKeyValueMatchCriterion creates a new mock instance.

func (*MockKeyValueMatchCriterion) EXPECT added in v0.21.0 

func (m *MockKeyValueMatchCriterion) EXPECT() *MockKeyValueMatchCriterionMockRecorder

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

func (*MockKeyValueMatchCriterion) Key added in v0.21.0 

func (m *MockKeyValueMatchCriterion) Key() string

Key mocks base method.

func (*MockKeyValueMatchCriterion) MatchType added in v0.21.0 

func (m *MockKeyValueMatchCriterion) MatchType() api.KeyValueMatchType

MatchType mocks base method.

func (*MockKeyValueMatchCriterion) Matcher added in v0.21.0 

func (m *MockKeyValueMatchCriterion) Matcher() string

Matcher mocks base method.

type MockKeyValueMatchCriterionMockRecorder added in v0.21.0 

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

MockKeyValueMatchCriterionMockRecorder is the mock recorder for MockKeyValueMatchCriterion.

func (*MockKeyValueMatchCriterionMockRecorder) Key added in v0.21.0 

func (mr *MockKeyValueMatchCriterionMockRecorder) Key() *gomock.Call

Key indicates an expected call of Key.

func (*MockKeyValueMatchCriterionMockRecorder) MatchType added in v0.21.0 

func (mr *MockKeyValueMatchCriterionMockRecorder) MatchType() *gomock.Call

MatchType indicates an expected call of MatchType.

func (*MockKeyValueMatchCriterionMockRecorder) Matcher added in v0.21.0 

func (mr *MockKeyValueMatchCriterionMockRecorder) Matcher() *gomock.Call

Matcher indicates an expected call of Matcher.

type MockLBOriDstInfo added in v0.17.0 

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

MockLBOriDstInfo is a mock of LBOriDstInfo interface.

func NewMockLBOriDstInfo added in v0.17.0 

func NewMockLBOriDstInfo(ctrl *gomock.Controller) *MockLBOriDstInfo

NewMockLBOriDstInfo creates a new mock instance.

func (*MockLBOriDstInfo) EXPECT added in v0.17.0 

func (m *MockLBOriDstInfo) EXPECT() *MockLBOriDstInfoMockRecorder

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

func (*MockLBOriDstInfo) GetHeader added in v0.17.0 

func (m *MockLBOriDstInfo) GetHeader() string

GetHeader mocks base method.

func (*MockLBOriDstInfo) IsEnabled added in v0.17.0 

func (m *MockLBOriDstInfo) IsEnabled() bool

IsEnabled mocks base method.

func (*MockLBOriDstInfo) IsReplaceLocal added in v1.1.0 

func (m *MockLBOriDstInfo) IsReplaceLocal() bool

IsReplaceLocal mocks base method.

type MockLBOriDstInfoMockRecorder added in v0.17.0 

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

MockLBOriDstInfoMockRecorder is the mock recorder for MockLBOriDstInfo.

func (*MockLBOriDstInfoMockRecorder) GetHeader added in v0.17.0 

func (mr *MockLBOriDstInfoMockRecorder) GetHeader() *gomock.Call

GetHeader indicates an expected call of GetHeader.

func (*MockLBOriDstInfoMockRecorder) IsEnabled added in v0.17.0 

func (mr *MockLBOriDstInfoMockRecorder) IsEnabled() *gomock.Call

IsEnabled indicates an expected call of IsEnabled.

func (*MockLBOriDstInfoMockRecorder) IsReplaceLocal added in v1.1.0 

func (mr *MockLBOriDstInfoMockRecorder) IsReplaceLocal() *gomock.Call

IsReplaceLocal indicates an expected call of IsReplaceLocal.

type MockLBSubsetInfo added in v0.17.0 

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

MockLBSubsetInfo is a mock of LBSubsetInfo interface.

func NewMockLBSubsetInfo added in v0.17.0 

func NewMockLBSubsetInfo(ctrl *gomock.Controller) *MockLBSubsetInfo

NewMockLBSubsetInfo creates a new mock instance.

func (*MockLBSubsetInfo) DefaultSubset added in v0.17.0 

func (m *MockLBSubsetInfo) DefaultSubset() types.SubsetMetadata

DefaultSubset mocks base method.

func (*MockLBSubsetInfo) EXPECT added in v0.17.0 

func (m *MockLBSubsetInfo) EXPECT() *MockLBSubsetInfoMockRecorder

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

func (*MockLBSubsetInfo) FallbackPolicy added in v0.17.0 

func (m *MockLBSubsetInfo) FallbackPolicy() types.FallBackPolicy

FallbackPolicy mocks base method.

func (*MockLBSubsetInfo) IsEnabled added in v0.17.0 

func (m *MockLBSubsetInfo) IsEnabled() bool

IsEnabled mocks base method.

func (*MockLBSubsetInfo) SubsetKeys added in v0.17.0 

func (m *MockLBSubsetInfo) SubsetKeys() []types.SortedStringSetType

SubsetKeys mocks base method.

type MockLBSubsetInfoMockRecorder added in v0.17.0 

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

MockLBSubsetInfoMockRecorder is the mock recorder for MockLBSubsetInfo.

func (*MockLBSubsetInfoMockRecorder) DefaultSubset added in v0.17.0 

func (mr *MockLBSubsetInfoMockRecorder) DefaultSubset() *gomock.Call

DefaultSubset indicates an expected call of DefaultSubset.

func (*MockLBSubsetInfoMockRecorder) FallbackPolicy added in v0.17.0 

func (mr *MockLBSubsetInfoMockRecorder) FallbackPolicy() *gomock.Call

FallbackPolicy indicates an expected call of FallbackPolicy.

func (*MockLBSubsetInfoMockRecorder) IsEnabled added in v0.17.0 

func (mr *MockLBSubsetInfoMockRecorder) IsEnabled() *gomock.Call

IsEnabled indicates an expected call of IsEnabled.

func (*MockLBSubsetInfoMockRecorder) SubsetKeys added in v0.17.0 

func (mr *MockLBSubsetInfoMockRecorder) SubsetKeys() *gomock.Call

SubsetKeys indicates an expected call of SubsetKeys.

type MockMatchable added in v0.21.0 

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

MockMatchable is a mock of Matchable interface.

func NewMockMatchable added in v0.21.0 

func NewMockMatchable(ctrl *gomock.Controller) *MockMatchable

NewMockMatchable creates a new mock instance.

func (*MockMatchable) EXPECT added in v0.21.0 

func (m *MockMatchable) EXPECT() *MockMatchableMockRecorder

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

func (*MockMatchable) Match added in v0.21.0 

func (m *MockMatchable) Match(ctx context.Context, headers api.HeaderMap) api.Route

Match mocks base method.

type MockMatchableMockRecorder added in v0.21.0 

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

MockMatchableMockRecorder is the mock recorder for MockMatchable.

func (*MockMatchableMockRecorder) Match added in v0.21.0 

func (mr *MockMatchableMockRecorder) Match(ctx, headers interface{}) *gomock.Call

Match indicates an expected call of Match.

type MockMetadataMatchCriteria added in v0.17.0 

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

MockMetadataMatchCriteria is a mock of MetadataMatchCriteria interface.

func NewMockMetadataMatchCriteria added in v0.17.0 

func NewMockMetadataMatchCriteria(ctrl *gomock.Controller) *MockMetadataMatchCriteria

NewMockMetadataMatchCriteria creates a new mock instance.

func (*MockMetadataMatchCriteria) EXPECT added in v0.17.0 

func (m *MockMetadataMatchCriteria) EXPECT() *MockMetadataMatchCriteriaMockRecorder

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

func (*MockMetadataMatchCriteria) MergeMatchCriteria added in v0.17.0 

func (m *MockMetadataMatchCriteria) MergeMatchCriteria(metadataMatches map[string]string) api.MetadataMatchCriteria

MergeMatchCriteria mocks base method.

func (*MockMetadataMatchCriteria) MetadataMatchCriteria added in v0.17.0 

func (m *MockMetadataMatchCriteria) MetadataMatchCriteria() []api.MetadataMatchCriterion

MetadataMatchCriteria mocks base method.

type MockMetadataMatchCriteriaMockRecorder added in v0.17.0 

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

MockMetadataMatchCriteriaMockRecorder is the mock recorder for MockMetadataMatchCriteria.

func (*MockMetadataMatchCriteriaMockRecorder) MergeMatchCriteria added in v0.17.0 

func (mr *MockMetadataMatchCriteriaMockRecorder) MergeMatchCriteria(metadataMatches interface{}) *gomock.Call

MergeMatchCriteria indicates an expected call of MergeMatchCriteria.

func (*MockMetadataMatchCriteriaMockRecorder) MetadataMatchCriteria added in v0.17.0 

func (mr *MockMetadataMatchCriteriaMockRecorder) MetadataMatchCriteria() *gomock.Call

MetadataMatchCriteria indicates an expected call of MetadataMatchCriteria.

type MockMetadataMatchCriterion added in v0.17.0 

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

MockMetadataMatchCriterion is a mock of MetadataMatchCriterion interface.

func NewMockMetadataMatchCriterion added in v0.17.0 

func NewMockMetadataMatchCriterion(ctrl *gomock.Controller) *MockMetadataMatchCriterion

NewMockMetadataMatchCriterion creates a new mock instance.

func (*MockMetadataMatchCriterion) EXPECT added in v0.17.0 

func (m *MockMetadataMatchCriterion) EXPECT() *MockMetadataMatchCriterionMockRecorder

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

func (*MockMetadataMatchCriterion) MetadataKeyName added in v0.17.0 

func (m *MockMetadataMatchCriterion) MetadataKeyName() string

MetadataKeyName mocks base method.

func (*MockMetadataMatchCriterion) MetadataValue added in v0.17.0 

func (m *MockMetadataMatchCriterion) MetadataValue() string

MetadataValue mocks base method.

type MockMetadataMatchCriterionMockRecorder added in v0.17.0 

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

MockMetadataMatchCriterionMockRecorder is the mock recorder for MockMetadataMatchCriterion.

func (*MockMetadataMatchCriterionMockRecorder) MetadataKeyName added in v0.17.0 

func (mr *MockMetadataMatchCriterionMockRecorder) MetadataKeyName() *gomock.Call

MetadataKeyName indicates an expected call of MetadataKeyName.

func (*MockMetadataMatchCriterionMockRecorder) MetadataValue added in v0.17.0 

func (mr *MockMetadataMatchCriterionMockRecorder) MetadataValue() *gomock.Call

MetadataValue indicates an expected call of MetadataValue.

type MockMirrorPolicy added in v0.17.0 

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

MockMirrorPolicy is a mock of MirrorPolicy interface.

func NewMockMirrorPolicy added in v0.17.0 

func NewMockMirrorPolicy(ctrl *gomock.Controller) *MockMirrorPolicy

NewMockMirrorPolicy creates a new mock instance.

func (*MockMirrorPolicy) ClusterName added in v0.17.0 

func (m *MockMirrorPolicy) ClusterName() string

ClusterName mocks base method.

func (*MockMirrorPolicy) EXPECT added in v0.17.0 

func (m *MockMirrorPolicy) EXPECT() *MockMirrorPolicyMockRecorder

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

func (*MockMirrorPolicy) IsMirror added in v0.17.0 

func (m *MockMirrorPolicy) IsMirror() bool

IsMirror mocks base method.

type MockMirrorPolicyMockRecorder added in v0.17.0 

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

MockMirrorPolicyMockRecorder is the mock recorder for MockMirrorPolicy.

func (*MockMirrorPolicyMockRecorder) ClusterName added in v0.17.0 

func (mr *MockMirrorPolicyMockRecorder) ClusterName() *gomock.Call

ClusterName indicates an expected call of ClusterName.

func (*MockMirrorPolicyMockRecorder) IsMirror added in v0.17.0 

func (mr *MockMirrorPolicyMockRecorder) IsMirror() *gomock.Call

IsMirror indicates an expected call of IsMirror.

type MockNetWorkFilterChainFactoryCallbacks 

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

MockNetWorkFilterChainFactoryCallbacks is a mock of NetWorkFilterChainFactoryCallbacks interface.

func NewMockNetWorkFilterChainFactoryCallbacks 

func NewMockNetWorkFilterChainFactoryCallbacks(ctrl *gomock.Controller) *MockNetWorkFilterChainFactoryCallbacks

NewMockNetWorkFilterChainFactoryCallbacks creates a new mock instance.

func (*MockNetWorkFilterChainFactoryCallbacks) AddReadFilter 

func (m *MockNetWorkFilterChainFactoryCallbacks) AddReadFilter(rf api.ReadFilter)

AddReadFilter mocks base method.

func (*MockNetWorkFilterChainFactoryCallbacks) AddWriteFilter 

func (m *MockNetWorkFilterChainFactoryCallbacks) AddWriteFilter(wf api.WriteFilter)

AddWriteFilter mocks base method.

func (*MockNetWorkFilterChainFactoryCallbacks) EXPECT 

func (m *MockNetWorkFilterChainFactoryCallbacks) EXPECT() *MockNetWorkFilterChainFactoryCallbacksMockRecorder

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

type MockNetWorkFilterChainFactoryCallbacksMockRecorder 

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

MockNetWorkFilterChainFactoryCallbacksMockRecorder is the mock recorder for MockNetWorkFilterChainFactoryCallbacks.

func (*MockNetWorkFilterChainFactoryCallbacksMockRecorder) AddReadFilter 

func (mr *MockNetWorkFilterChainFactoryCallbacksMockRecorder) AddReadFilter(rf interface{}) *gomock.Call

AddReadFilter indicates an expected call of AddReadFilter.

func (*MockNetWorkFilterChainFactoryCallbacksMockRecorder) AddWriteFilter 

func (mr *MockNetWorkFilterChainFactoryCallbacksMockRecorder) AddWriteFilter(wf interface{}) *gomock.Call

AddWriteFilter indicates an expected call of AddWriteFilter.

type MockNetworkFilterChainFactory 

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

MockNetworkFilterChainFactory is a mock of NetworkFilterChainFactory interface.

func NewMockNetworkFilterChainFactory 

func NewMockNetworkFilterChainFactory(ctrl *gomock.Controller) *MockNetworkFilterChainFactory

NewMockNetworkFilterChainFactory creates a new mock instance.

func (*MockNetworkFilterChainFactory) CreateFilterChain 

func (m *MockNetworkFilterChainFactory) CreateFilterChain(context context.Context, callbacks api.NetWorkFilterChainFactoryCallbacks)

CreateFilterChain mocks base method.

func (*MockNetworkFilterChainFactory) EXPECT 

func (m *MockNetworkFilterChainFactory) EXPECT() *MockNetworkFilterChainFactoryMockRecorder

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

type MockNetworkFilterChainFactoryMockRecorder 

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

MockNetworkFilterChainFactoryMockRecorder is the mock recorder for MockNetworkFilterChainFactory.

func (*MockNetworkFilterChainFactoryMockRecorder) CreateFilterChain 

func (mr *MockNetworkFilterChainFactoryMockRecorder) CreateFilterChain(context, callbacks interface{}) *gomock.Call

CreateFilterChain indicates an expected call of CreateFilterChain.

type MockPathMatchCriterion added in v0.17.0 

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

MockPathMatchCriterion is a mock of PathMatchCriterion interface.

func NewMockPathMatchCriterion added in v0.17.0 

func NewMockPathMatchCriterion(ctrl *gomock.Controller) *MockPathMatchCriterion

NewMockPathMatchCriterion creates a new mock instance.

func (*MockPathMatchCriterion) EXPECT added in v0.17.0 

func (m *MockPathMatchCriterion) EXPECT() *MockPathMatchCriterionMockRecorder

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

func (*MockPathMatchCriterion) MatchType added in v0.17.0 

func (m *MockPathMatchCriterion) MatchType() api.PathMatchType

MatchType mocks base method.

func (*MockPathMatchCriterion) Matcher added in v0.17.0 

func (m *MockPathMatchCriterion) Matcher() string

Matcher mocks base method.

type MockPathMatchCriterionMockRecorder added in v0.17.0 

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

MockPathMatchCriterionMockRecorder is the mock recorder for MockPathMatchCriterion.

func (*MockPathMatchCriterionMockRecorder) MatchType added in v0.17.0 

func (mr *MockPathMatchCriterionMockRecorder) MatchType() *gomock.Call

MatchType indicates an expected call of MatchType.

func (*MockPathMatchCriterionMockRecorder) Matcher added in v0.17.0 

func (mr *MockPathMatchCriterionMockRecorder) Matcher() *gomock.Call

Matcher indicates an expected call of Matcher.

type MockPolicy added in v0.17.0 

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

MockPolicy is a mock of Policy interface.

func NewMockPolicy added in v0.17.0 

func NewMockPolicy(ctrl *gomock.Controller) *MockPolicy

NewMockPolicy creates a new mock instance.

func (*MockPolicy) EXPECT added in v0.17.0 

func (m *MockPolicy) EXPECT() *MockPolicyMockRecorder

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

func (*MockPolicy) HashPolicy added in v0.17.0 

func (m *MockPolicy) HashPolicy() api.HashPolicy

HashPolicy mocks base method.

func (*MockPolicy) MirrorPolicy added in v0.17.0 

func (m *MockPolicy) MirrorPolicy() api.MirrorPolicy

MirrorPolicy mocks base method.

func (*MockPolicy) RetryPolicy added in v0.17.0 

func (m *MockPolicy) RetryPolicy() api.RetryPolicy

RetryPolicy mocks base method.

func (*MockPolicy) ShadowPolicy added in v0.17.0 

func (m *MockPolicy) ShadowPolicy() api.ShadowPolicy

ShadowPolicy mocks base method.

type MockPolicyMockRecorder added in v0.17.0 

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

MockPolicyMockRecorder is the mock recorder for MockPolicy.

func (*MockPolicyMockRecorder) HashPolicy added in v0.17.0 

func (mr *MockPolicyMockRecorder) HashPolicy() *gomock.Call

HashPolicy indicates an expected call of HashPolicy.

func (*MockPolicyMockRecorder) MirrorPolicy added in v0.17.0 

func (mr *MockPolicyMockRecorder) MirrorPolicy() *gomock.Call

MirrorPolicy indicates an expected call of MirrorPolicy.

func (*MockPolicyMockRecorder) RetryPolicy added in v0.17.0 

func (mr *MockPolicyMockRecorder) RetryPolicy() *gomock.Call

RetryPolicy indicates an expected call of RetryPolicy.

func (*MockPolicyMockRecorder) ShadowPolicy added in v0.17.0 

func (mr *MockPolicyMockRecorder) ShadowPolicy() *gomock.Call

ShadowPolicy indicates an expected call of ShadowPolicy.

type MockProtocolStreamFactory added in v0.27.0 

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

MockProtocolStreamFactory is a mock of ProtocolStreamFactory interface.

func NewMockProtocolStreamFactory added in v0.27.0 

func NewMockProtocolStreamFactory(ctrl *gomock.Controller) *MockProtocolStreamFactory

NewMockProtocolStreamFactory creates a new mock instance.

func (*MockProtocolStreamFactory) CreateBiDirectStream added in v0.27.0 

func (m *MockProtocolStreamFactory) CreateBiDirectStream(context context.Context, connection types.ClientConnection, clientCallbacks types.StreamConnectionEventListener, serverCallbacks types.ServerStreamConnectionEventListener) types.ClientStreamConnection

CreateBiDirectStream mocks base method.

func (*MockProtocolStreamFactory) CreateClientStream added in v0.27.0 

func (m *MockProtocolStreamFactory) CreateClientStream(context context.Context, connection types.ClientConnection, streamConnCallbacks types.StreamConnectionEventListener, callbacks api.ConnectionEventListener) types.ClientStreamConnection

CreateClientStream mocks base method.

func (*MockProtocolStreamFactory) CreateServerStream added in v0.27.0 

func (m *MockProtocolStreamFactory) CreateServerStream(context context.Context, connection api.Connection, callbacks types.ServerStreamConnectionEventListener) types.ServerStreamConnection

CreateServerStream mocks base method.

func (*MockProtocolStreamFactory) EXPECT added in v0.27.0 

func (m *MockProtocolStreamFactory) EXPECT() *MockProtocolStreamFactoryMockRecorder

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

func (*MockProtocolStreamFactory) ProtocolMatch added in v0.27.0 

func (m *MockProtocolStreamFactory) ProtocolMatch(context context.Context, prot string, magic []byte) error

ProtocolMatch mocks base method.

type MockProtocolStreamFactoryMockRecorder added in v0.27.0 

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

MockProtocolStreamFactoryMockRecorder is the mock recorder for MockProtocolStreamFactory.

func (*MockProtocolStreamFactoryMockRecorder) CreateBiDirectStream added in v0.27.0 

func (mr *MockProtocolStreamFactoryMockRecorder) CreateBiDirectStream(context, connection, clientCallbacks, serverCallbacks interface{}) *gomock.Call

CreateBiDirectStream indicates an expected call of CreateBiDirectStream.

func (*MockProtocolStreamFactoryMockRecorder) CreateClientStream added in v0.27.0 

func (mr *MockProtocolStreamFactoryMockRecorder) CreateClientStream(context, connection, streamConnCallbacks, callbacks interface{}) *gomock.Call

CreateClientStream indicates an expected call of CreateClientStream.

func (*MockProtocolStreamFactoryMockRecorder) CreateServerStream added in v0.27.0 

func (mr *MockProtocolStreamFactoryMockRecorder) CreateServerStream(context, connection, callbacks interface{}) *gomock.Call

CreateServerStream indicates an expected call of CreateServerStream.

func (*MockProtocolStreamFactoryMockRecorder) ProtocolMatch added in v0.27.0 

func (mr *MockProtocolStreamFactoryMockRecorder) ProtocolMatch(context, prot, magic interface{}) *gomock.Call

ProtocolMatch indicates an expected call of ProtocolMatch.

type MockQueryParameterMatcher 

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

MockQueryParameterMatcher is a mock of QueryParameterMatcher interface.

func NewMockQueryParameterMatcher 

func NewMockQueryParameterMatcher(ctrl *gomock.Controller) *MockQueryParameterMatcher

NewMockQueryParameterMatcher creates a new mock instance.

func (*MockQueryParameterMatcher) EXPECT 

func (m *MockQueryParameterMatcher) EXPECT() *MockQueryParameterMatcherMockRecorder

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

func (*MockQueryParameterMatcher) Matches 

func (m *MockQueryParameterMatcher) Matches(ctx context.Context, requestQueryParams types.QueryParams) bool

Matches mocks base method.

type MockQueryParameterMatcherMockRecorder 

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

MockQueryParameterMatcherMockRecorder is the mock recorder for MockQueryParameterMatcher.

func (*MockQueryParameterMatcherMockRecorder) Matches 

func (mr *MockQueryParameterMatcherMockRecorder) Matches(ctx, requestQueryParams interface{}) *gomock.Call

Matches indicates an expected call of Matches.

type MockReadFilter 

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

MockReadFilter is a mock of ReadFilter interface.

func NewMockReadFilter 

func NewMockReadFilter(ctrl *gomock.Controller) *MockReadFilter

NewMockReadFilter creates a new mock instance.

func (*MockReadFilter) EXPECT 

func (m *MockReadFilter) EXPECT() *MockReadFilterMockRecorder

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

func (*MockReadFilter) InitializeReadFilterCallbacks 

func (m *MockReadFilter) InitializeReadFilterCallbacks(cb api.ReadFilterCallbacks)

InitializeReadFilterCallbacks mocks base method.

func (*MockReadFilter) OnData 

func (m *MockReadFilter) OnData(buffer api.IoBuffer) api.FilterStatus

OnData mocks base method.

func (*MockReadFilter) OnNewConnection 

func (m *MockReadFilter) OnNewConnection() api.FilterStatus

OnNewConnection mocks base method.

type MockReadFilterCallbacks 

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

MockReadFilterCallbacks is a mock of ReadFilterCallbacks interface.

func NewMockReadFilterCallbacks 

func NewMockReadFilterCallbacks(ctrl *gomock.Controller) *MockReadFilterCallbacks

NewMockReadFilterCallbacks creates a new mock instance.

func (*MockReadFilterCallbacks) Connection 

func (m *MockReadFilterCallbacks) Connection() api.Connection

Connection mocks base method.

func (*MockReadFilterCallbacks) ContinueReading 

func (m *MockReadFilterCallbacks) ContinueReading()

ContinueReading mocks base method.

func (*MockReadFilterCallbacks) EXPECT 

func (m *MockReadFilterCallbacks) EXPECT() *MockReadFilterCallbacksMockRecorder

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

func (*MockReadFilterCallbacks) SetUpstreamHost 

func (m *MockReadFilterCallbacks) SetUpstreamHost(upstreamHost api.HostInfo)

SetUpstreamHost mocks base method.

func (*MockReadFilterCallbacks) UpstreamHost 

func (m *MockReadFilterCallbacks) UpstreamHost() api.HostInfo

UpstreamHost mocks base method.

type MockReadFilterCallbacksMockRecorder 

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

MockReadFilterCallbacksMockRecorder is the mock recorder for MockReadFilterCallbacks.

func (*MockReadFilterCallbacksMockRecorder) Connection 

func (mr *MockReadFilterCallbacksMockRecorder) Connection() *gomock.Call

Connection indicates an expected call of Connection.

func (*MockReadFilterCallbacksMockRecorder) ContinueReading 

func (mr *MockReadFilterCallbacksMockRecorder) ContinueReading() *gomock.Call

ContinueReading indicates an expected call of ContinueReading.

func (*MockReadFilterCallbacksMockRecorder) SetUpstreamHost 

func (mr *MockReadFilterCallbacksMockRecorder) SetUpstreamHost(upstreamHost interface{}) *gomock.Call

SetUpstreamHost indicates an expected call of SetUpstreamHost.

func (*MockReadFilterCallbacksMockRecorder) UpstreamHost 

func (mr *MockReadFilterCallbacksMockRecorder) UpstreamHost() *gomock.Call

UpstreamHost indicates an expected call of UpstreamHost.

type MockReadFilterMockRecorder 

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

MockReadFilterMockRecorder is the mock recorder for MockReadFilter.

func (*MockReadFilterMockRecorder) InitializeReadFilterCallbacks 

func (mr *MockReadFilterMockRecorder) InitializeReadFilterCallbacks(cb interface{}) *gomock.Call

InitializeReadFilterCallbacks indicates an expected call of InitializeReadFilterCallbacks.

func (*MockReadFilterMockRecorder) OnData 

func (mr *MockReadFilterMockRecorder) OnData(buffer interface{}) *gomock.Call

OnData indicates an expected call of OnData.

func (*MockReadFilterMockRecorder) OnNewConnection 

func (mr *MockReadFilterMockRecorder) OnNewConnection() *gomock.Call

OnNewConnection indicates an expected call of OnNewConnection.

type MockRedirectRule added in v0.17.0 

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

MockRedirectRule is a mock of RedirectRule interface.

func NewMockRedirectRule added in v0.17.0 

func NewMockRedirectRule(ctrl *gomock.Controller) *MockRedirectRule

NewMockRedirectRule creates a new mock instance.

func (*MockRedirectRule) EXPECT added in v0.17.0 

func (m *MockRedirectRule) EXPECT() *MockRedirectRuleMockRecorder

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

func (*MockRedirectRule) RedirectCode added in v0.17.0 

func (m *MockRedirectRule) RedirectCode() int

RedirectCode mocks base method.

func (*MockRedirectRule) RedirectHost added in v0.17.0 

func (m *MockRedirectRule) RedirectHost() string

RedirectHost mocks base method.

func (*MockRedirectRule) RedirectPath added in v0.17.0 

func (m *MockRedirectRule) RedirectPath() string

RedirectPath mocks base method.

func (*MockRedirectRule) RedirectScheme added in v0.17.0 

func (m *MockRedirectRule) RedirectScheme() string

RedirectScheme mocks base method.

type MockRedirectRuleMockRecorder added in v0.17.0 

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

MockRedirectRuleMockRecorder is the mock recorder for MockRedirectRule.

func (*MockRedirectRuleMockRecorder) RedirectCode added in v0.17.0 

func (mr *MockRedirectRuleMockRecorder) RedirectCode() *gomock.Call

RedirectCode indicates an expected call of RedirectCode.

func (*MockRedirectRuleMockRecorder) RedirectHost added in v0.17.0 

func (mr *MockRedirectRuleMockRecorder) RedirectHost() *gomock.Call

RedirectHost indicates an expected call of RedirectHost.

func (*MockRedirectRuleMockRecorder) RedirectPath added in v0.17.0 

func (mr *MockRedirectRuleMockRecorder) RedirectPath() *gomock.Call

RedirectPath indicates an expected call of RedirectPath.

func (*MockRedirectRuleMockRecorder) RedirectScheme added in v0.17.0 

func (mr *MockRedirectRuleMockRecorder) RedirectScheme() *gomock.Call

RedirectScheme indicates an expected call of RedirectScheme.

type MockRegisterUpstreamUpdateMethodCb added in v0.17.0 

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

MockRegisterUpstreamUpdateMethodCb is a mock of RegisterUpstreamUpdateMethodCb interface.

func NewMockRegisterUpstreamUpdateMethodCb added in v0.17.0 

func NewMockRegisterUpstreamUpdateMethodCb(ctrl *gomock.Controller) *MockRegisterUpstreamUpdateMethodCb

NewMockRegisterUpstreamUpdateMethodCb creates a new mock instance.

func (*MockRegisterUpstreamUpdateMethodCb) EXPECT added in v0.17.0 

func (m *MockRegisterUpstreamUpdateMethodCb) EXPECT() *MockRegisterUpstreamUpdateMethodCbMockRecorder

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

func (*MockRegisterUpstreamUpdateMethodCb) GetClusterNameByServiceName added in v0.17.0 

func (m *MockRegisterUpstreamUpdateMethodCb) GetClusterNameByServiceName(serviceName string) string

GetClusterNameByServiceName mocks base method.

func (*MockRegisterUpstreamUpdateMethodCb) TriggerClusterUpdate added in v0.17.0 

func (m *MockRegisterUpstreamUpdateMethodCb) TriggerClusterUpdate(clusterName string, hosts []v2.Host)

TriggerClusterUpdate mocks base method.

type MockRegisterUpstreamUpdateMethodCbMockRecorder added in v0.17.0 

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

MockRegisterUpstreamUpdateMethodCbMockRecorder is the mock recorder for MockRegisterUpstreamUpdateMethodCb.

func (*MockRegisterUpstreamUpdateMethodCbMockRecorder) GetClusterNameByServiceName added in v0.17.0 

func (mr *MockRegisterUpstreamUpdateMethodCbMockRecorder) GetClusterNameByServiceName(serviceName interface{}) *gomock.Call

GetClusterNameByServiceName indicates an expected call of GetClusterNameByServiceName.

func (*MockRegisterUpstreamUpdateMethodCbMockRecorder) TriggerClusterUpdate added in v0.17.0 

func (mr *MockRegisterUpstreamUpdateMethodCbMockRecorder) TriggerClusterUpdate(clusterName, hosts interface{}) *gomock.Call

TriggerClusterUpdate indicates an expected call of TriggerClusterUpdate.

type MockResource added in v0.17.0 

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

MockResource is a mock of Resource interface.

func NewMockResource added in v0.17.0 

func NewMockResource(ctrl *gomock.Controller) *MockResource

NewMockResource creates a new mock instance.

func (*MockResource) CanCreate added in v0.17.0 

func (m *MockResource) CanCreate() bool

CanCreate mocks base method.

func (*MockResource) Cur added in v0.17.0 

func (m *MockResource) Cur() int64

Cur mocks base method.

func (*MockResource) Decrease added in v0.17.0 

func (m *MockResource) Decrease()

Decrease mocks base method.

func (*MockResource) EXPECT added in v0.17.0 

func (m *MockResource) EXPECT() *MockResourceMockRecorder

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

func (*MockResource) Increase added in v0.17.0 

func (m *MockResource) Increase()

Increase mocks base method.

func (*MockResource) Max added in v0.17.0 

func (m *MockResource) Max() uint64

Max mocks base method.

func (*MockResource) UpdateCur added in v0.17.0 

func (m *MockResource) UpdateCur(arg0 int64)

UpdateCur mocks base method.

type MockResourceManager added in v0.17.0 

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

MockResourceManager is a mock of ResourceManager interface.

func NewMockResourceManager added in v0.17.0 

func NewMockResourceManager(ctrl *gomock.Controller) *MockResourceManager

NewMockResourceManager creates a new mock instance.

func (*MockResourceManager) Connections added in v0.17.0 

func (m *MockResourceManager) Connections() types.Resource

Connections mocks base method.

func (*MockResourceManager) EXPECT added in v0.17.0 

func (m *MockResourceManager) EXPECT() *MockResourceManagerMockRecorder

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

func (*MockResourceManager) PendingRequests added in v0.17.0 

func (m *MockResourceManager) PendingRequests() types.Resource

PendingRequests mocks base method.

func (*MockResourceManager) Requests added in v0.17.0 

func (m *MockResourceManager) Requests() types.Resource

Requests mocks base method.

func (*MockResourceManager) Retries added in v0.17.0 

func (m *MockResourceManager) Retries() types.Resource

Retries mocks base method.

type MockResourceManagerMockRecorder added in v0.17.0 

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

MockResourceManagerMockRecorder is the mock recorder for MockResourceManager.

func (*MockResourceManagerMockRecorder) Connections added in v0.17.0 

func (mr *MockResourceManagerMockRecorder) Connections() *gomock.Call

Connections indicates an expected call of Connections.

func (*MockResourceManagerMockRecorder) PendingRequests added in v0.17.0 

func (mr *MockResourceManagerMockRecorder) PendingRequests() *gomock.Call

PendingRequests indicates an expected call of PendingRequests.

func (*MockResourceManagerMockRecorder) Requests added in v0.17.0 

func (mr *MockResourceManagerMockRecorder) Requests() *gomock.Call

Requests indicates an expected call of Requests.

func (*MockResourceManagerMockRecorder) Retries added in v0.17.0 

func (mr *MockResourceManagerMockRecorder) Retries() *gomock.Call

Retries indicates an expected call of Retries.

type MockResourceMockRecorder added in v0.17.0 

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

MockResourceMockRecorder is the mock recorder for MockResource.

func (*MockResourceMockRecorder) CanCreate added in v0.17.0 

func (mr *MockResourceMockRecorder) CanCreate() *gomock.Call

CanCreate indicates an expected call of CanCreate.

func (*MockResourceMockRecorder) Cur added in v0.17.0 

func (mr *MockResourceMockRecorder) Cur() *gomock.Call

Cur indicates an expected call of Cur.

func (*MockResourceMockRecorder) Decrease added in v0.17.0 

func (mr *MockResourceMockRecorder) Decrease() *gomock.Call

Decrease indicates an expected call of Decrease.

func (*MockResourceMockRecorder) Increase added in v0.17.0 

func (mr *MockResourceMockRecorder) Increase() *gomock.Call

Increase indicates an expected call of Increase.

func (*MockResourceMockRecorder) Max added in v0.17.0 

func (mr *MockResourceMockRecorder) Max() *gomock.Call

Max indicates an expected call of Max.

func (*MockResourceMockRecorder) UpdateCur added in v0.17.0 

func (mr *MockResourceMockRecorder) UpdateCur(arg0 interface{}) *gomock.Call

UpdateCur indicates an expected call of UpdateCur.

type MockRetryPolicy added in v0.17.0 

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

MockRetryPolicy is a mock of RetryPolicy interface.

func NewMockRetryPolicy added in v0.17.0 

func NewMockRetryPolicy(ctrl *gomock.Controller) *MockRetryPolicy

NewMockRetryPolicy creates a new mock instance.

func (*MockRetryPolicy) EXPECT added in v0.17.0 

func (m *MockRetryPolicy) EXPECT() *MockRetryPolicyMockRecorder

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

func (*MockRetryPolicy) NumRetries added in v0.17.0 

func (m *MockRetryPolicy) NumRetries() uint32

NumRetries mocks base method.

func (*MockRetryPolicy) RetryOn added in v0.17.0 

func (m *MockRetryPolicy) RetryOn() bool

RetryOn mocks base method.

func (*MockRetryPolicy) RetryableStatusCodes added in v1.2.0 

func (m *MockRetryPolicy) RetryableStatusCodes() []uint32

RetryableStatusCodes mocks base method.

func (*MockRetryPolicy) TryTimeout added in v0.17.0 

func (m *MockRetryPolicy) TryTimeout() time.Duration

TryTimeout mocks base method.

type MockRetryPolicyMockRecorder added in v0.17.0 

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

MockRetryPolicyMockRecorder is the mock recorder for MockRetryPolicy.

func (*MockRetryPolicyMockRecorder) NumRetries added in v0.17.0 

func (mr *MockRetryPolicyMockRecorder) NumRetries() *gomock.Call

NumRetries indicates an expected call of NumRetries.

func (*MockRetryPolicyMockRecorder) RetryOn added in v0.17.0 

func (mr *MockRetryPolicyMockRecorder) RetryOn() *gomock.Call

RetryOn indicates an expected call of RetryOn.

func (*MockRetryPolicyMockRecorder) RetryableStatusCodes added in v1.2.0 

func (mr *MockRetryPolicyMockRecorder) RetryableStatusCodes() *gomock.Call

RetryableStatusCodes indicates an expected call of RetryableStatusCodes.

func (*MockRetryPolicyMockRecorder) TryTimeout added in v0.17.0 

func (mr *MockRetryPolicyMockRecorder) TryTimeout() *gomock.Call

TryTimeout indicates an expected call of TryTimeout.

type MockRetryState added in v0.17.0 

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

MockRetryState is a mock of RetryState interface.

func NewMockRetryState added in v0.17.0 

func NewMockRetryState(ctrl *gomock.Controller) *MockRetryState

NewMockRetryState creates a new mock instance.

func (*MockRetryState) EXPECT added in v0.17.0 

func (m *MockRetryState) EXPECT() *MockRetryStateMockRecorder

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

func (*MockRetryState) Enabled added in v0.17.0 

func (m *MockRetryState) Enabled() bool

Enabled mocks base method.

func (*MockRetryState) ShouldRetry added in v0.17.0 

func (m *MockRetryState) ShouldRetry(respHeaders map[string]string, resetReson string, doRetryCb api.DoRetryCallback) bool

ShouldRetry mocks base method.

type MockRetryStateMockRecorder added in v0.17.0 

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

MockRetryStateMockRecorder is the mock recorder for MockRetryState.

func (*MockRetryStateMockRecorder) Enabled added in v0.17.0 

func (mr *MockRetryStateMockRecorder) Enabled() *gomock.Call

Enabled indicates an expected call of Enabled.

func (*MockRetryStateMockRecorder) ShouldRetry added in v0.17.0 

func (mr *MockRetryStateMockRecorder) ShouldRetry(respHeaders, resetReson, doRetryCb interface{}) *gomock.Call

ShouldRetry indicates an expected call of ShouldRetry.

type MockRoute added in v0.17.0 

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

MockRoute is a mock of Route interface.

func NewMockRoute added in v0.17.0 

func NewMockRoute(ctrl *gomock.Controller) *MockRoute

NewMockRoute creates a new mock instance.

func (*MockRoute) DirectResponseRule added in v0.17.0 

func (m *MockRoute) DirectResponseRule() api.DirectResponseRule

DirectResponseRule mocks base method.

func (*MockRoute) EXPECT added in v0.17.0 

func (m *MockRoute) EXPECT() *MockRouteMockRecorder

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

func (*MockRoute) RedirectRule added in v0.17.0 

func (m *MockRoute) RedirectRule() api.RedirectRule

RedirectRule mocks base method.

func (*MockRoute) RouteRule added in v0.17.0 

func (m *MockRoute) RouteRule() api.RouteRule

RouteRule mocks base method.

type MockRouteBase added in v0.21.0 

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

MockRouteBase is a mock of RouteBase interface.

func NewMockRouteBase added in v0.21.0 

func NewMockRouteBase(ctrl *gomock.Controller) *MockRouteBase

NewMockRouteBase creates a new mock instance.

func (*MockRouteBase) DirectResponseRule added in v0.21.0 

func (m *MockRouteBase) DirectResponseRule() api.DirectResponseRule

DirectResponseRule mocks base method.

func (*MockRouteBase) EXPECT added in v0.21.0 

func (m *MockRouteBase) EXPECT() *MockRouteBaseMockRecorder

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

func (*MockRouteBase) Match added in v0.21.0 

func (m *MockRouteBase) Match(ctx context.Context, headers api.HeaderMap) api.Route

Match mocks base method.

func (*MockRouteBase) RedirectRule added in v0.21.0 

func (m *MockRouteBase) RedirectRule() api.RedirectRule

RedirectRule mocks base method.

func (*MockRouteBase) RouteRule added in v0.21.0 

func (m *MockRouteBase) RouteRule() api.RouteRule

RouteRule mocks base method.

type MockRouteBaseMockRecorder added in v0.21.0 

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

MockRouteBaseMockRecorder is the mock recorder for MockRouteBase.

func (*MockRouteBaseMockRecorder) DirectResponseRule added in v0.21.0 

func (mr *MockRouteBaseMockRecorder) DirectResponseRule() *gomock.Call

DirectResponseRule indicates an expected call of DirectResponseRule.

func (*MockRouteBaseMockRecorder) Match added in v0.21.0 

func (mr *MockRouteBaseMockRecorder) Match(ctx, headers interface{}) *gomock.Call

Match indicates an expected call of Match.

func (*MockRouteBaseMockRecorder) RedirectRule added in v0.21.0 

func (mr *MockRouteBaseMockRecorder) RedirectRule() *gomock.Call

RedirectRule indicates an expected call of RedirectRule.

func (*MockRouteBaseMockRecorder) RouteRule added in v0.21.0 

func (mr *MockRouteBaseMockRecorder) RouteRule() *gomock.Call

RouteRule indicates an expected call of RouteRule.

type MockRouteHandler 

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

MockRouteHandler is a mock of RouteHandler interface.

func NewMockRouteHandler 

func NewMockRouteHandler(ctrl *gomock.Controller) *MockRouteHandler

NewMockRouteHandler creates a new mock instance.

func (*MockRouteHandler) EXPECT 

func (m *MockRouteHandler) EXPECT() *MockRouteHandlerMockRecorder

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

func (*MockRouteHandler) IsAvailable 

func (m *MockRouteHandler) IsAvailable(arg0 context.Context, arg1 types.ClusterManager) (types.ClusterSnapshot, types.HandlerStatus)

IsAvailable mocks base method.

func (*MockRouteHandler) Route 

func (m *MockRouteHandler) Route() api.Route

Route mocks base method.

type MockRouteHandlerMockRecorder 

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

MockRouteHandlerMockRecorder is the mock recorder for MockRouteHandler.

func (*MockRouteHandlerMockRecorder) IsAvailable 

func (mr *MockRouteHandlerMockRecorder) IsAvailable(arg0, arg1 interface{}) *gomock.Call

IsAvailable indicates an expected call of IsAvailable.

func (*MockRouteHandlerMockRecorder) Route 

func (mr *MockRouteHandlerMockRecorder) Route() *gomock.Call

Route indicates an expected call of Route.

type MockRouteMockRecorder added in v0.17.0 

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

MockRouteMockRecorder is the mock recorder for MockRoute.

func (*MockRouteMockRecorder) DirectResponseRule added in v0.17.0 

func (mr *MockRouteMockRecorder) DirectResponseRule() *gomock.Call

DirectResponseRule indicates an expected call of DirectResponseRule.

func (*MockRouteMockRecorder) RedirectRule added in v0.17.0 

func (mr *MockRouteMockRecorder) RedirectRule() *gomock.Call

RedirectRule indicates an expected call of RedirectRule.

func (*MockRouteMockRecorder) RouteRule added in v0.17.0 

func (mr *MockRouteMockRecorder) RouteRule() *gomock.Call

RouteRule indicates an expected call of RouteRule.

type MockRouteRule added in v0.17.0 

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

MockRouteRule is a mock of RouteRule interface.

func NewMockRouteRule added in v0.17.0 

func NewMockRouteRule(ctrl *gomock.Controller) *MockRouteRule

NewMockRouteRule creates a new mock instance.

func (*MockRouteRule) ClusterName added in v0.17.0 

func (m *MockRouteRule) ClusterName(ctx context.Context) string

ClusterName mocks base method.

func (*MockRouteRule) EXPECT added in v0.17.0 

func (m *MockRouteRule) EXPECT() *MockRouteRuleMockRecorder

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

func (*MockRouteRule) FinalizeRequestHeaders added in v0.17.0 

func (m *MockRouteRule) FinalizeRequestHeaders(ctx context.Context, headers api.HeaderMap, requestInfo api.RequestInfo)

FinalizeRequestHeaders mocks base method.

func (*MockRouteRule) FinalizeResponseHeaders added in v0.17.0 

func (m *MockRouteRule) FinalizeResponseHeaders(ctx context.Context, headers api.HeaderMap, requestInfo api.RequestInfo)

FinalizeResponseHeaders mocks base method.

func (*MockRouteRule) GlobalTimeout added in v0.17.0 

func (m *MockRouteRule) GlobalTimeout() time.Duration

GlobalTimeout mocks base method.

func (*MockRouteRule) HeaderMatchCriteria added in v0.21.0 

func (m *MockRouteRule) HeaderMatchCriteria() api.KeyValueMatchCriteria

HeaderMatchCriteria mocks base method.

func (*MockRouteRule) MetadataMatchCriteria added in v0.17.0 

func (m *MockRouteRule) MetadataMatchCriteria(clusterName string) api.MetadataMatchCriteria

MetadataMatchCriteria mocks base method.

func (*MockRouteRule) PathMatchCriterion added in v0.17.0 

func (m *MockRouteRule) PathMatchCriterion() api.PathMatchCriterion

PathMatchCriterion mocks base method.

func (*MockRouteRule) PerFilterConfig added in v0.17.0 

func (m *MockRouteRule) PerFilterConfig() map[string]interface{}

PerFilterConfig mocks base method.

func (*MockRouteRule) Policy added in v0.17.0 

func (m *MockRouteRule) Policy() api.Policy

Policy mocks base method.

func (*MockRouteRule) UpstreamProtocol added in v0.17.0 

func (m *MockRouteRule) UpstreamProtocol() string

UpstreamProtocol mocks base method.

func (*MockRouteRule) VirtualHost added in v0.21.0 

func (m *MockRouteRule) VirtualHost() api.VirtualHost

VirtualHost mocks base method.

type MockRouteRuleMockRecorder added in v0.17.0 

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

MockRouteRuleMockRecorder is the mock recorder for MockRouteRule.

func (*MockRouteRuleMockRecorder) ClusterName added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) ClusterName(ctx interface{}) *gomock.Call

ClusterName indicates an expected call of ClusterName.

func (*MockRouteRuleMockRecorder) FinalizeRequestHeaders added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) FinalizeRequestHeaders(ctx, headers, requestInfo interface{}) *gomock.Call

FinalizeRequestHeaders indicates an expected call of FinalizeRequestHeaders.

func (*MockRouteRuleMockRecorder) FinalizeResponseHeaders added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) FinalizeResponseHeaders(ctx, headers, requestInfo interface{}) *gomock.Call

FinalizeResponseHeaders indicates an expected call of FinalizeResponseHeaders.

func (*MockRouteRuleMockRecorder) GlobalTimeout added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) GlobalTimeout() *gomock.Call

GlobalTimeout indicates an expected call of GlobalTimeout.

func (*MockRouteRuleMockRecorder) HeaderMatchCriteria added in v0.21.0 

func (mr *MockRouteRuleMockRecorder) HeaderMatchCriteria() *gomock.Call

HeaderMatchCriteria indicates an expected call of HeaderMatchCriteria.

func (*MockRouteRuleMockRecorder) MetadataMatchCriteria added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) MetadataMatchCriteria(clusterName interface{}) *gomock.Call

MetadataMatchCriteria indicates an expected call of MetadataMatchCriteria.

func (*MockRouteRuleMockRecorder) PathMatchCriterion added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) PathMatchCriterion() *gomock.Call

PathMatchCriterion indicates an expected call of PathMatchCriterion.

func (*MockRouteRuleMockRecorder) PerFilterConfig added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) PerFilterConfig() *gomock.Call

PerFilterConfig indicates an expected call of PerFilterConfig.

func (*MockRouteRuleMockRecorder) Policy added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) Policy() *gomock.Call

Policy indicates an expected call of Policy.

func (*MockRouteRuleMockRecorder) UpstreamProtocol added in v0.17.0 

func (mr *MockRouteRuleMockRecorder) UpstreamProtocol() *gomock.Call

UpstreamProtocol indicates an expected call of UpstreamProtocol.

func (*MockRouteRuleMockRecorder) VirtualHost added in v0.21.0 

func (mr *MockRouteRuleMockRecorder) VirtualHost() *gomock.Call

VirtualHost indicates an expected call of VirtualHost.

type MockRouterManager 

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

MockRouterManager is a mock of RouterManager interface.

func NewMockRouterManager 

func NewMockRouterManager(ctrl *gomock.Controller) *MockRouterManager

NewMockRouterManager creates a new mock instance.

func (*MockRouterManager) AddOrUpdateRouters 

func (m *MockRouterManager) AddOrUpdateRouters(routerConfig *v2.RouterConfiguration) error

AddOrUpdateRouters mocks base method.

func (*MockRouterManager) AddRoute 

func (m *MockRouterManager) AddRoute(routerConfigName, domain string, route *v2.Router) error

AddRoute mocks base method.

func (*MockRouterManager) EXPECT 

func (m *MockRouterManager) EXPECT() *MockRouterManagerMockRecorder

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

func (*MockRouterManager) GetRouterWrapperByName 

func (m *MockRouterManager) GetRouterWrapperByName(routerConfigName string) types.RouterWrapper

GetRouterWrapperByName mocks base method.

func (*MockRouterManager) RemoveAllRoutes 

func (m *MockRouterManager) RemoveAllRoutes(routerConfigName, domain string) error

RemoveAllRoutes mocks base method.

type MockRouterManagerMockRecorder 

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

MockRouterManagerMockRecorder is the mock recorder for MockRouterManager.

func (*MockRouterManagerMockRecorder) AddOrUpdateRouters 

func (mr *MockRouterManagerMockRecorder) AddOrUpdateRouters(routerConfig interface{}) *gomock.Call

AddOrUpdateRouters indicates an expected call of AddOrUpdateRouters.

func (*MockRouterManagerMockRecorder) AddRoute 

func (mr *MockRouterManagerMockRecorder) AddRoute(routerConfigName, domain, route interface{}) *gomock.Call

AddRoute indicates an expected call of AddRoute.

func (*MockRouterManagerMockRecorder) GetRouterWrapperByName 

func (mr *MockRouterManagerMockRecorder) GetRouterWrapperByName(routerConfigName interface{}) *gomock.Call

GetRouterWrapperByName indicates an expected call of GetRouterWrapperByName.

func (*MockRouterManagerMockRecorder) RemoveAllRoutes 

func (mr *MockRouterManagerMockRecorder) RemoveAllRoutes(routerConfigName, domain interface{}) *gomock.Call

RemoveAllRoutes indicates an expected call of RemoveAllRoutes.

type MockRouterWrapper 

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

MockRouterWrapper is a mock of RouterWrapper interface.

func NewMockRouterWrapper 

func NewMockRouterWrapper(ctrl *gomock.Controller) *MockRouterWrapper

NewMockRouterWrapper creates a new mock instance.

func (*MockRouterWrapper) EXPECT 

func (m *MockRouterWrapper) EXPECT() *MockRouterWrapperMockRecorder

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

func (*MockRouterWrapper) GetRouters 

func (m *MockRouterWrapper) GetRouters() types.Routers

GetRouters mocks base method.

func (*MockRouterWrapper) GetRoutersConfig 

func (m *MockRouterWrapper) GetRoutersConfig() v2.RouterConfiguration

GetRoutersConfig mocks base method.

type MockRouterWrapperMockRecorder 

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

MockRouterWrapperMockRecorder is the mock recorder for MockRouterWrapper.

func (*MockRouterWrapperMockRecorder) GetRouters 

func (mr *MockRouterWrapperMockRecorder) GetRouters() *gomock.Call

GetRouters indicates an expected call of GetRouters.

func (*MockRouterWrapperMockRecorder) GetRoutersConfig 

func (mr *MockRouterWrapperMockRecorder) GetRoutersConfig() *gomock.Call

GetRoutersConfig indicates an expected call of GetRoutersConfig.

type MockRouters 

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

MockRouters is a mock of Routers interface.

func NewMockRouters 

func NewMockRouters(ctrl *gomock.Controller) *MockRouters

NewMockRouters creates a new mock instance.

func (*MockRouters) AddRoute 

func (m *MockRouters) AddRoute(domain string, route *v2.Router) int

AddRoute mocks base method.

func (*MockRouters) EXPECT 

func (m *MockRouters) EXPECT() *MockRoutersMockRecorder

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

func (*MockRouters) MatchAllRoutes 

func (m *MockRouters) MatchAllRoutes(ctx context.Context, headers api.HeaderMap) []api.Route

MatchAllRoutes mocks base method.

func (*MockRouters) MatchRoute 

func (m *MockRouters) MatchRoute(ctx context.Context, headers api.HeaderMap) api.Route

MatchRoute mocks base method.

func (*MockRouters) MatchRouteFromHeaderKV 

func (m *MockRouters) MatchRouteFromHeaderKV(ctx context.Context, headers api.HeaderMap, key, value string) api.Route

MatchRouteFromHeaderKV mocks base method.

func (*MockRouters) RemoveAllRoutes 

func (m *MockRouters) RemoveAllRoutes(domain string) int

RemoveAllRoutes mocks base method.

type MockRoutersMockRecorder 

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

MockRoutersMockRecorder is the mock recorder for MockRouters.

func (*MockRoutersMockRecorder) AddRoute 

func (mr *MockRoutersMockRecorder) AddRoute(domain, route interface{}) *gomock.Call

AddRoute indicates an expected call of AddRoute.

func (*MockRoutersMockRecorder) MatchAllRoutes 

func (mr *MockRoutersMockRecorder) MatchAllRoutes(ctx, headers interface{}) *gomock.Call

MatchAllRoutes indicates an expected call of MatchAllRoutes.

func (*MockRoutersMockRecorder) MatchRoute 

func (mr *MockRoutersMockRecorder) MatchRoute(ctx, headers interface{}) *gomock.Call

MatchRoute indicates an expected call of MatchRoute.

func (*MockRoutersMockRecorder) MatchRouteFromHeaderKV 

func (mr *MockRoutersMockRecorder) MatchRouteFromHeaderKV(ctx, headers, key, value interface{}) *gomock.Call

MatchRouteFromHeaderKV indicates an expected call of MatchRouteFromHeaderKV.

func (*MockRoutersMockRecorder) RemoveAllRoutes 

func (mr *MockRoutersMockRecorder) RemoveAllRoutes(domain interface{}) *gomock.Call

RemoveAllRoutes indicates an expected call of RemoveAllRoutes.

type MockSdsClient added in v0.27.0 

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

MockSdsClient is a mock of SdsClient interface.

func NewMockSdsClient added in v0.27.0 

func NewMockSdsClient(ctrl *gomock.Controller) *MockSdsClient

NewMockSdsClient creates a new mock instance.

func (*MockSdsClient) AckResponse added in v0.27.0 

func (m *MockSdsClient) AckResponse(resp interface{})

AckResponse mocks base method.

func (*MockSdsClient) AddUpdateCallback added in v0.27.0 

func (m *MockSdsClient) AddUpdateCallback(name string, callback types.SdsUpdateCallbackFunc) error

AddUpdateCallback mocks base method.

func (*MockSdsClient) DeleteUpdateCallback added in v0.27.0 

func (m *MockSdsClient) DeleteUpdateCallback(name string) error

DeleteUpdateCallback mocks base method.

func (*MockSdsClient) EXPECT added in v0.27.0 

func (m *MockSdsClient) EXPECT() *MockSdsClientMockRecorder

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

func (*MockSdsClient) FetchSecret added in v0.27.0 

func (m *MockSdsClient) FetchSecret(ctx context.Context, name string) (*types.SdsSecret, error)

FetchSecret mocks base method.

func (*MockSdsClient) RequireSecret added in v0.27.0 

func (m *MockSdsClient) RequireSecret(name string)

RequireSecret mocks base method.

func (*MockSdsClient) SetSecret added in v0.27.0 

func (m *MockSdsClient) SetSecret(name string, secret *types.SdsSecret)

SetSecret mocks base method.

type MockSdsClientMockRecorder added in v0.27.0 

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

MockSdsClientMockRecorder is the mock recorder for MockSdsClient.

func (*MockSdsClientMockRecorder) AckResponse added in v0.27.0 

func (mr *MockSdsClientMockRecorder) AckResponse(resp interface{}) *gomock.Call

AckResponse indicates an expected call of AckResponse.

func (*MockSdsClientMockRecorder) AddUpdateCallback added in v0.27.0 

func (mr *MockSdsClientMockRecorder) AddUpdateCallback(name, callback interface{}) *gomock.Call

AddUpdateCallback indicates an expected call of AddUpdateCallback.

func (*MockSdsClientMockRecorder) DeleteUpdateCallback added in v0.27.0 

func (mr *MockSdsClientMockRecorder) DeleteUpdateCallback(name interface{}) *gomock.Call

DeleteUpdateCallback indicates an expected call of DeleteUpdateCallback.

func (*MockSdsClientMockRecorder) FetchSecret added in v0.27.0 

func (mr *MockSdsClientMockRecorder) FetchSecret(ctx, name interface{}) *gomock.Call

FetchSecret indicates an expected call of FetchSecret.

func (*MockSdsClientMockRecorder) RequireSecret added in v0.27.0 

func (mr *MockSdsClientMockRecorder) RequireSecret(name interface{}) *gomock.Call

RequireSecret indicates an expected call of RequireSecret.

func (*MockSdsClientMockRecorder) SetSecret added in v0.27.0 

func (mr *MockSdsClientMockRecorder) SetSecret(name, secret interface{}) *gomock.Call

SetSecret indicates an expected call of SetSecret.

type MockSecretProvider added in v0.27.0 

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

MockSecretProvider is a mock of SecretProvider interface.

func NewMockSecretProvider added in v0.27.0 

func NewMockSecretProvider(ctrl *gomock.Controller) *MockSecretProvider

NewMockSecretProvider creates a new mock instance.

func (*MockSecretProvider) AckResponse added in v0.27.0 

func (m *MockSecretProvider) AckResponse(resp interface{})

AckResponse mocks base method.

func (*MockSecretProvider) EXPECT added in v0.27.0 

func (m *MockSecretProvider) EXPECT() *MockSecretProviderMockRecorder

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

func (*MockSecretProvider) SetSecret added in v0.27.0 

func (m *MockSecretProvider) SetSecret(name string, secret *types.SdsSecret)

SetSecret mocks base method.

type MockSecretProviderMockRecorder added in v0.27.0 

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

MockSecretProviderMockRecorder is the mock recorder for MockSecretProvider.

func (*MockSecretProviderMockRecorder) AckResponse added in v0.27.0 

func (mr *MockSecretProviderMockRecorder) AckResponse(resp interface{}) *gomock.Call

AckResponse indicates an expected call of AckResponse.

func (*MockSecretProviderMockRecorder) SetSecret added in v0.27.0 

func (mr *MockSecretProviderMockRecorder) SetSecret(name, secret interface{}) *gomock.Call

SetSecret indicates an expected call of SetSecret.

type MockServerStreamConnection 

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

MockServerStreamConnection is a mock of ServerStreamConnection interface.

func NewMockServerStreamConnection 

func NewMockServerStreamConnection(ctrl *gomock.Controller) *MockServerStreamConnection

NewMockServerStreamConnection creates a new mock instance.

func (*MockServerStreamConnection) ActiveStreamsNum 

func (m *MockServerStreamConnection) ActiveStreamsNum() int

ActiveStreamsNum mocks base method.

func (*MockServerStreamConnection) CheckReasonError 

func (m *MockServerStreamConnection) CheckReasonError(connected bool, event api.ConnectionEvent) (types.StreamResetReason, bool)

CheckReasonError mocks base method.

func (*MockServerStreamConnection) Dispatch 

func (m *MockServerStreamConnection) Dispatch(buffer buffer.IoBuffer)

Dispatch mocks base method.

func (*MockServerStreamConnection) EXPECT 

func (m *MockServerStreamConnection) EXPECT() *MockServerStreamConnectionMockRecorder

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

func (*MockServerStreamConnection) EnableWorkerPool added in v0.17.0 

func (m *MockServerStreamConnection) EnableWorkerPool() bool

EnableWorkerPool mocks base method.

func (*MockServerStreamConnection) GoAway 

func (m *MockServerStreamConnection) GoAway()

GoAway mocks base method.

func (*MockServerStreamConnection) Protocol 

func (m *MockServerStreamConnection) Protocol() api.ProtocolName

Protocol mocks base method.

func (*MockServerStreamConnection) Reset 

func (m *MockServerStreamConnection) Reset(reason types.StreamResetReason)

Reset mocks base method.

type MockServerStreamConnectionEventListener 

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

MockServerStreamConnectionEventListener is a mock of ServerStreamConnectionEventListener interface.

func NewMockServerStreamConnectionEventListener 

func NewMockServerStreamConnectionEventListener(ctrl *gomock.Controller) *MockServerStreamConnectionEventListener

NewMockServerStreamConnectionEventListener creates a new mock instance.

func (*MockServerStreamConnectionEventListener) EXPECT 

func (m *MockServerStreamConnectionEventListener) EXPECT() *MockServerStreamConnectionEventListenerMockRecorder

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

func (*MockServerStreamConnectionEventListener) NewStreamDetect 

func (m *MockServerStreamConnectionEventListener) NewStreamDetect(context context.Context, sender types.StreamSender, span api.Span) types.StreamReceiveListener

NewStreamDetect mocks base method.

func (*MockServerStreamConnectionEventListener) OnGoAway 

func (m *MockServerStreamConnectionEventListener) OnGoAway()

OnGoAway mocks base method.

type MockServerStreamConnectionEventListenerMockRecorder 

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

MockServerStreamConnectionEventListenerMockRecorder is the mock recorder for MockServerStreamConnectionEventListener.

func (*MockServerStreamConnectionEventListenerMockRecorder) NewStreamDetect 

func (mr *MockServerStreamConnectionEventListenerMockRecorder) NewStreamDetect(context, sender, span interface{}) *gomock.Call

NewStreamDetect indicates an expected call of NewStreamDetect.

func (*MockServerStreamConnectionEventListenerMockRecorder) OnGoAway 

func (mr *MockServerStreamConnectionEventListenerMockRecorder) OnGoAway() *gomock.Call

OnGoAway indicates an expected call of OnGoAway.

type MockServerStreamConnectionMockRecorder 

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

MockServerStreamConnectionMockRecorder is the mock recorder for MockServerStreamConnection.

func (*MockServerStreamConnectionMockRecorder) ActiveStreamsNum 

func (mr *MockServerStreamConnectionMockRecorder) ActiveStreamsNum() *gomock.Call

ActiveStreamsNum indicates an expected call of ActiveStreamsNum.

func (*MockServerStreamConnectionMockRecorder) CheckReasonError 

func (mr *MockServerStreamConnectionMockRecorder) CheckReasonError(connected, event interface{}) *gomock.Call

CheckReasonError indicates an expected call of CheckReasonError.

func (*MockServerStreamConnectionMockRecorder) Dispatch 

func (mr *MockServerStreamConnectionMockRecorder) Dispatch(buffer interface{}) *gomock.Call

Dispatch indicates an expected call of Dispatch.

func (*MockServerStreamConnectionMockRecorder) EnableWorkerPool added in v0.17.0 

func (mr *MockServerStreamConnectionMockRecorder) EnableWorkerPool() *gomock.Call

EnableWorkerPool indicates an expected call of EnableWorkerPool.

func (*MockServerStreamConnectionMockRecorder) GoAway 

func (mr *MockServerStreamConnectionMockRecorder) GoAway() *gomock.Call

GoAway indicates an expected call of GoAway.

func (*MockServerStreamConnectionMockRecorder) Protocol 

func (mr *MockServerStreamConnectionMockRecorder) Protocol() *gomock.Call

Protocol indicates an expected call of Protocol.

func (*MockServerStreamConnectionMockRecorder) Reset 

func (mr *MockServerStreamConnectionMockRecorder) Reset(reason interface{}) *gomock.Call

Reset indicates an expected call of Reset.

type MockShadowPolicy added in v0.17.0 

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

MockShadowPolicy is a mock of ShadowPolicy interface.

func NewMockShadowPolicy added in v0.17.0 

func NewMockShadowPolicy(ctrl *gomock.Controller) *MockShadowPolicy

NewMockShadowPolicy creates a new mock instance.

func (*MockShadowPolicy) ClusterName added in v0.17.0 

func (m *MockShadowPolicy) ClusterName() string

ClusterName mocks base method.

func (*MockShadowPolicy) EXPECT added in v0.17.0 

func (m *MockShadowPolicy) EXPECT() *MockShadowPolicyMockRecorder

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

func (*MockShadowPolicy) RuntimeKey added in v0.17.0 

func (m *MockShadowPolicy) RuntimeKey() string

RuntimeKey mocks base method.

type MockShadowPolicyMockRecorder added in v0.17.0 

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

MockShadowPolicyMockRecorder is the mock recorder for MockShadowPolicy.

func (*MockShadowPolicyMockRecorder) ClusterName added in v0.17.0 

func (mr *MockShadowPolicyMockRecorder) ClusterName() *gomock.Call

ClusterName indicates an expected call of ClusterName.

func (*MockShadowPolicyMockRecorder) RuntimeKey added in v0.17.0 

func (mr *MockShadowPolicyMockRecorder) RuntimeKey() *gomock.Call

RuntimeKey indicates an expected call of RuntimeKey.

type MockSimpleCluster added in v0.17.0 

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

MockSimpleCluster is a mock of SimpleCluster interface.

func NewMockSimpleCluster added in v0.17.0 

func NewMockSimpleCluster(ctrl *gomock.Controller) *MockSimpleCluster

NewMockSimpleCluster creates a new mock instance.

func (*MockSimpleCluster) EXPECT added in v0.17.0 

func (m *MockSimpleCluster) EXPECT() *MockSimpleClusterMockRecorder

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

func (*MockSimpleCluster) UpdateHosts added in v0.17.0 

func (m *MockSimpleCluster) UpdateHosts(newHosts []types.Host)

UpdateHosts mocks base method.

type MockSimpleClusterMockRecorder added in v0.17.0 

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

MockSimpleClusterMockRecorder is the mock recorder for MockSimpleCluster.

func (*MockSimpleClusterMockRecorder) UpdateHosts added in v0.17.0 

func (mr *MockSimpleClusterMockRecorder) UpdateHosts(newHosts interface{}) *gomock.Call

UpdateHosts indicates an expected call of UpdateHosts.

type MockSpan 

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

MockSpan is a mock of Span interface.

func NewMockSpan 

func NewMockSpan(ctrl *gomock.Controller) *MockSpan

NewMockSpan creates a new mock instance.

func (*MockSpan) EXPECT 

func (m *MockSpan) EXPECT() *MockSpanMockRecorder

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

func (*MockSpan) FinishSpan 

func (m *MockSpan) FinishSpan()

FinishSpan mocks base method.

func (*MockSpan) InjectContext 

func (m *MockSpan) InjectContext(requestHeaders api.HeaderMap, requestInfo api.RequestInfo)

InjectContext mocks base method.

func (*MockSpan) ParentSpanId 

func (m *MockSpan) ParentSpanId() string

ParentSpanId mocks base method.

func (*MockSpan) SetOperation 

func (m *MockSpan) SetOperation(operation string)

SetOperation mocks base method.

func (*MockSpan) SetRequestInfo 

func (m *MockSpan) SetRequestInfo(requestInfo api.RequestInfo)

SetRequestInfo mocks base method.

func (*MockSpan) SetTag 

func (m *MockSpan) SetTag(key uint64, value string)

SetTag mocks base method.

func (*MockSpan) SpanId 

func (m *MockSpan) SpanId() string

SpanId mocks base method.

func (*MockSpan) SpawnChild 

func (m *MockSpan) SpawnChild(operationName string, startTime time.Time) api.Span

SpawnChild mocks base method.

func (*MockSpan) Tag 

func (m *MockSpan) Tag(key uint64) string

Tag mocks base method.

func (*MockSpan) TraceId 

func (m *MockSpan) TraceId() string

TraceId mocks base method.

type MockSpanMockRecorder 

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

MockSpanMockRecorder is the mock recorder for MockSpan.

func (*MockSpanMockRecorder) FinishSpan 

func (mr *MockSpanMockRecorder) FinishSpan() *gomock.Call

FinishSpan indicates an expected call of FinishSpan.

func (*MockSpanMockRecorder) InjectContext 

func (mr *MockSpanMockRecorder) InjectContext(requestHeaders, requestInfo interface{}) *gomock.Call

InjectContext indicates an expected call of InjectContext.

func (*MockSpanMockRecorder) ParentSpanId 

func (mr *MockSpanMockRecorder) ParentSpanId() *gomock.Call

ParentSpanId indicates an expected call of ParentSpanId.

func (*MockSpanMockRecorder) SetOperation 

func (mr *MockSpanMockRecorder) SetOperation(operation interface{}) *gomock.Call

SetOperation indicates an expected call of SetOperation.

func (*MockSpanMockRecorder) SetRequestInfo 

func (mr *MockSpanMockRecorder) SetRequestInfo(requestInfo interface{}) *gomock.Call

SetRequestInfo indicates an expected call of SetRequestInfo.

func (*MockSpanMockRecorder) SetTag 

func (mr *MockSpanMockRecorder) SetTag(key, value interface{}) *gomock.Call

SetTag indicates an expected call of SetTag.

func (*MockSpanMockRecorder) SpanId 

func (mr *MockSpanMockRecorder) SpanId() *gomock.Call

SpanId indicates an expected call of SpanId.

func (*MockSpanMockRecorder) SpawnChild 

func (mr *MockSpanMockRecorder) SpawnChild(operationName, startTime interface{}) *gomock.Call

SpawnChild indicates an expected call of SpawnChild.

func (*MockSpanMockRecorder) Tag 

func (mr *MockSpanMockRecorder) Tag(key interface{}) *gomock.Call

Tag indicates an expected call of Tag.

func (*MockSpanMockRecorder) TraceId 

func (mr *MockSpanMockRecorder) TraceId() *gomock.Call

TraceId indicates an expected call of TraceId.

type MockStream 

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

MockStream is a mock of Stream interface.

func NewMockStream 

func NewMockStream(ctrl *gomock.Controller) *MockStream

NewMockStream creates a new mock instance.

func (*MockStream) AddEventListener 

func (m *MockStream) AddEventListener(streamEventListener types.StreamEventListener)

AddEventListener mocks base method.

func (*MockStream) DestroyStream 

func (m *MockStream) DestroyStream()

DestroyStream mocks base method.

func (*MockStream) EXPECT 

func (m *MockStream) EXPECT() *MockStreamMockRecorder

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

func (*MockStream) ID 

func (m *MockStream) ID() uint64

ID mocks base method.

func (*MockStream) RemoveEventListener 

func (m *MockStream) RemoveEventListener(streamEventListener types.StreamEventListener)

RemoveEventListener mocks base method.

func (*MockStream) ResetStream 

func (m *MockStream) ResetStream(reason types.StreamResetReason)

ResetStream mocks base method.

type MockStreamConnection 

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

MockStreamConnection is a mock of StreamConnection interface.

func NewMockStreamConnection 

func NewMockStreamConnection(ctrl *gomock.Controller) *MockStreamConnection

NewMockStreamConnection creates a new mock instance.

func (*MockStreamConnection) ActiveStreamsNum 

func (m *MockStreamConnection) ActiveStreamsNum() int

ActiveStreamsNum mocks base method.

func (*MockStreamConnection) CheckReasonError 

func (m *MockStreamConnection) CheckReasonError(connected bool, event api.ConnectionEvent) (types.StreamResetReason, bool)

CheckReasonError mocks base method.

func (*MockStreamConnection) Dispatch 

func (m *MockStreamConnection) Dispatch(buffer buffer.IoBuffer)

Dispatch mocks base method.

func (*MockStreamConnection) EXPECT 

func (m *MockStreamConnection) EXPECT() *MockStreamConnectionMockRecorder

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

func (*MockStreamConnection) EnableWorkerPool added in v0.17.0 

func (m *MockStreamConnection) EnableWorkerPool() bool

EnableWorkerPool mocks base method.

func (*MockStreamConnection) GoAway 

func (m *MockStreamConnection) GoAway()

GoAway mocks base method.

func (*MockStreamConnection) Protocol 

func (m *MockStreamConnection) Protocol() api.ProtocolName

Protocol mocks base method.

func (*MockStreamConnection) Reset 

func (m *MockStreamConnection) Reset(reason types.StreamResetReason)

Reset mocks base method.

type MockStreamConnectionEventListener 

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

MockStreamConnectionEventListener is a mock of StreamConnectionEventListener interface.

func NewMockStreamConnectionEventListener 

func NewMockStreamConnectionEventListener(ctrl *gomock.Controller) *MockStreamConnectionEventListener

NewMockStreamConnectionEventListener creates a new mock instance.

func (*MockStreamConnectionEventListener) EXPECT 

func (m *MockStreamConnectionEventListener) EXPECT() *MockStreamConnectionEventListenerMockRecorder

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

func (*MockStreamConnectionEventListener) OnGoAway 

func (m *MockStreamConnectionEventListener) OnGoAway()

OnGoAway mocks base method.

type MockStreamConnectionEventListenerMockRecorder 

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

MockStreamConnectionEventListenerMockRecorder is the mock recorder for MockStreamConnectionEventListener.

func (*MockStreamConnectionEventListenerMockRecorder) OnGoAway 

func (mr *MockStreamConnectionEventListenerMockRecorder) OnGoAway() *gomock.Call

OnGoAway indicates an expected call of OnGoAway.

type MockStreamConnectionMockRecorder 

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

MockStreamConnectionMockRecorder is the mock recorder for MockStreamConnection.

func (*MockStreamConnectionMockRecorder) ActiveStreamsNum 

func (mr *MockStreamConnectionMockRecorder) ActiveStreamsNum() *gomock.Call

ActiveStreamsNum indicates an expected call of ActiveStreamsNum.

func (*MockStreamConnectionMockRecorder) CheckReasonError 

func (mr *MockStreamConnectionMockRecorder) CheckReasonError(connected, event interface{}) *gomock.Call

CheckReasonError indicates an expected call of CheckReasonError.

func (*MockStreamConnectionMockRecorder) Dispatch 

func (mr *MockStreamConnectionMockRecorder) Dispatch(buffer interface{}) *gomock.Call

Dispatch indicates an expected call of Dispatch.

func (*MockStreamConnectionMockRecorder) EnableWorkerPool added in v0.17.0 

func (mr *MockStreamConnectionMockRecorder) EnableWorkerPool() *gomock.Call

EnableWorkerPool indicates an expected call of EnableWorkerPool.

func (*MockStreamConnectionMockRecorder) GoAway 

func (mr *MockStreamConnectionMockRecorder) GoAway() *gomock.Call

GoAway indicates an expected call of GoAway.

func (*MockStreamConnectionMockRecorder) Protocol 

func (mr *MockStreamConnectionMockRecorder) Protocol() *gomock.Call

Protocol indicates an expected call of Protocol.

func (*MockStreamConnectionMockRecorder) Reset 

func (mr *MockStreamConnectionMockRecorder) Reset(reason interface{}) *gomock.Call

Reset indicates an expected call of Reset.

type MockStreamEventListener 

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

MockStreamEventListener is a mock of StreamEventListener interface.

func NewMockStreamEventListener 

func NewMockStreamEventListener(ctrl *gomock.Controller) *MockStreamEventListener

NewMockStreamEventListener creates a new mock instance.

func (*MockStreamEventListener) EXPECT 

func (m *MockStreamEventListener) EXPECT() *MockStreamEventListenerMockRecorder

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

func (*MockStreamEventListener) OnDestroyStream 

func (m *MockStreamEventListener) OnDestroyStream()

OnDestroyStream mocks base method.

func (*MockStreamEventListener) OnResetStream 

func (m *MockStreamEventListener) OnResetStream(reason types.StreamResetReason)

OnResetStream mocks base method.

type MockStreamEventListenerMockRecorder 

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

MockStreamEventListenerMockRecorder is the mock recorder for MockStreamEventListener.

func (*MockStreamEventListenerMockRecorder) OnDestroyStream 

func (mr *MockStreamEventListenerMockRecorder) OnDestroyStream() *gomock.Call

OnDestroyStream indicates an expected call of OnDestroyStream.

func (*MockStreamEventListenerMockRecorder) OnResetStream 

func (mr *MockStreamEventListenerMockRecorder) OnResetStream(reason interface{}) *gomock.Call

OnResetStream indicates an expected call of OnResetStream.

type MockStreamFilterBase 

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

MockStreamFilterBase is a mock of StreamFilterBase interface.

func NewMockStreamFilterBase 

func NewMockStreamFilterBase(ctrl *gomock.Controller) *MockStreamFilterBase

NewMockStreamFilterBase creates a new mock instance.

func (*MockStreamFilterBase) EXPECT 

func (m *MockStreamFilterBase) EXPECT() *MockStreamFilterBaseMockRecorder

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

func (*MockStreamFilterBase) OnDestroy 

func (m *MockStreamFilterBase) OnDestroy()

OnDestroy mocks base method.

type MockStreamFilterBaseMockRecorder 

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

MockStreamFilterBaseMockRecorder is the mock recorder for MockStreamFilterBase.

func (*MockStreamFilterBaseMockRecorder) OnDestroy 

func (mr *MockStreamFilterBaseMockRecorder) OnDestroy() *gomock.Call

OnDestroy indicates an expected call of OnDestroy.

type MockStreamFilterChainFactory 

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

MockStreamFilterChainFactory is a mock of StreamFilterChainFactory interface.

func NewMockStreamFilterChainFactory 

func NewMockStreamFilterChainFactory(ctrl *gomock.Controller) *MockStreamFilterChainFactory

NewMockStreamFilterChainFactory creates a new mock instance.

func (*MockStreamFilterChainFactory) CreateFilterChain 

func (m *MockStreamFilterChainFactory) CreateFilterChain(context context.Context, callbacks api.StreamFilterChainFactoryCallbacks)

CreateFilterChain mocks base method.

func (*MockStreamFilterChainFactory) EXPECT 

func (m *MockStreamFilterChainFactory) EXPECT() *MockStreamFilterChainFactoryMockRecorder

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

type MockStreamFilterChainFactoryCallbacks 

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

MockStreamFilterChainFactoryCallbacks is a mock of StreamFilterChainFactoryCallbacks interface.

func NewMockStreamFilterChainFactoryCallbacks 

func NewMockStreamFilterChainFactoryCallbacks(ctrl *gomock.Controller) *MockStreamFilterChainFactoryCallbacks

NewMockStreamFilterChainFactoryCallbacks creates a new mock instance.

func (*MockStreamFilterChainFactoryCallbacks) AddStreamAccessLog 

func (m *MockStreamFilterChainFactoryCallbacks) AddStreamAccessLog(accessLog api.AccessLog)

AddStreamAccessLog mocks base method.

func (*MockStreamFilterChainFactoryCallbacks) AddStreamReceiverFilter 

func (m *MockStreamFilterChainFactoryCallbacks) AddStreamReceiverFilter(filter api.StreamReceiverFilter, p api.ReceiverFilterPhase)

AddStreamReceiverFilter mocks base method.

func (*MockStreamFilterChainFactoryCallbacks) AddStreamSenderFilter 

func (m *MockStreamFilterChainFactoryCallbacks) AddStreamSenderFilter(filter api.StreamSenderFilter, p api.SenderFilterPhase)

AddStreamSenderFilter mocks base method.

func (*MockStreamFilterChainFactoryCallbacks) EXPECT 

func (m *MockStreamFilterChainFactoryCallbacks) EXPECT() *MockStreamFilterChainFactoryCallbacksMockRecorder

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

type MockStreamFilterChainFactoryCallbacksMockRecorder 

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

MockStreamFilterChainFactoryCallbacksMockRecorder is the mock recorder for MockStreamFilterChainFactoryCallbacks.

func (*MockStreamFilterChainFactoryCallbacksMockRecorder) AddStreamAccessLog 

func (mr *MockStreamFilterChainFactoryCallbacksMockRecorder) AddStreamAccessLog(accessLog interface{}) *gomock.Call

AddStreamAccessLog indicates an expected call of AddStreamAccessLog.

func (*MockStreamFilterChainFactoryCallbacksMockRecorder) AddStreamReceiverFilter 

func (mr *MockStreamFilterChainFactoryCallbacksMockRecorder) AddStreamReceiverFilter(filter, p interface{}) *gomock.Call

AddStreamReceiverFilter indicates an expected call of AddStreamReceiverFilter.

func (*MockStreamFilterChainFactoryCallbacksMockRecorder) AddStreamSenderFilter 

func (mr *MockStreamFilterChainFactoryCallbacksMockRecorder) AddStreamSenderFilter(filter, p interface{}) *gomock.Call

AddStreamSenderFilter indicates an expected call of AddStreamSenderFilter.

type MockStreamFilterChainFactoryMockRecorder 

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

MockStreamFilterChainFactoryMockRecorder is the mock recorder for MockStreamFilterChainFactory.

func (*MockStreamFilterChainFactoryMockRecorder) CreateFilterChain 

func (mr *MockStreamFilterChainFactoryMockRecorder) CreateFilterChain(context, callbacks interface{}) *gomock.Call

CreateFilterChain indicates an expected call of CreateFilterChain.

type MockStreamFilterHandler 

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

MockStreamFilterHandler is a mock of StreamFilterHandler interface.

func NewMockStreamFilterHandler 

func NewMockStreamFilterHandler(ctrl *gomock.Controller) *MockStreamFilterHandler

NewMockStreamFilterHandler creates a new mock instance.

func (*MockStreamFilterHandler) Connection 

func (m *MockStreamFilterHandler) Connection() api.Connection

Connection mocks base method.

func (*MockStreamFilterHandler) EXPECT 

func (m *MockStreamFilterHandler) EXPECT() *MockStreamFilterHandlerMockRecorder

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

func (*MockStreamFilterHandler) RequestInfo 

func (m *MockStreamFilterHandler) RequestInfo() api.RequestInfo

RequestInfo mocks base method.

func (*MockStreamFilterHandler) Route 

func (m *MockStreamFilterHandler) Route() api.Route

Route mocks base method.

type MockStreamFilterHandlerMockRecorder 

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

MockStreamFilterHandlerMockRecorder is the mock recorder for MockStreamFilterHandler.

func (*MockStreamFilterHandlerMockRecorder) Connection 

func (mr *MockStreamFilterHandlerMockRecorder) Connection() *gomock.Call

Connection indicates an expected call of Connection.

func (*MockStreamFilterHandlerMockRecorder) RequestInfo 

func (mr *MockStreamFilterHandlerMockRecorder) RequestInfo() *gomock.Call

RequestInfo indicates an expected call of RequestInfo.

func (*MockStreamFilterHandlerMockRecorder) Route 

func (mr *MockStreamFilterHandlerMockRecorder) Route() *gomock.Call

Route indicates an expected call of Route.

type MockStreamMockRecorder 

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

MockStreamMockRecorder is the mock recorder for MockStream.

func (*MockStreamMockRecorder) AddEventListener 

func (mr *MockStreamMockRecorder) AddEventListener(streamEventListener interface{}) *gomock.Call

AddEventListener indicates an expected call of AddEventListener.

func (*MockStreamMockRecorder) DestroyStream 

func (mr *MockStreamMockRecorder) DestroyStream() *gomock.Call

DestroyStream indicates an expected call of DestroyStream.

func (*MockStreamMockRecorder) ID 

func (mr *MockStreamMockRecorder) ID() *gomock.Call

ID indicates an expected call of ID.

func (*MockStreamMockRecorder) RemoveEventListener 

func (mr *MockStreamMockRecorder) RemoveEventListener(streamEventListener interface{}) *gomock.Call

RemoveEventListener indicates an expected call of RemoveEventListener.

func (*MockStreamMockRecorder) ResetStream 

func (mr *MockStreamMockRecorder) ResetStream(reason interface{}) *gomock.Call

ResetStream indicates an expected call of ResetStream.

type MockStreamReceiveListener 

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

MockStreamReceiveListener is a mock of StreamReceiveListener interface.

func NewMockStreamReceiveListener 

func NewMockStreamReceiveListener(ctrl *gomock.Controller) *MockStreamReceiveListener

NewMockStreamReceiveListener creates a new mock instance.

func (*MockStreamReceiveListener) EXPECT 

func (m *MockStreamReceiveListener) EXPECT() *MockStreamReceiveListenerMockRecorder

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

func (*MockStreamReceiveListener) OnDecodeError 

func (m *MockStreamReceiveListener) OnDecodeError(ctx context.Context, err error, headers api.HeaderMap)

OnDecodeError mocks base method.

func (*MockStreamReceiveListener) OnReceive 

func (m *MockStreamReceiveListener) OnReceive(ctx context.Context, headers api.HeaderMap, data buffer.IoBuffer, trailers api.HeaderMap)

OnReceive mocks base method.

type MockStreamReceiveListenerMockRecorder 

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

MockStreamReceiveListenerMockRecorder is the mock recorder for MockStreamReceiveListener.

func (*MockStreamReceiveListenerMockRecorder) OnDecodeError 

func (mr *MockStreamReceiveListenerMockRecorder) OnDecodeError(ctx, err, headers interface{}) *gomock.Call

OnDecodeError indicates an expected call of OnDecodeError.

func (*MockStreamReceiveListenerMockRecorder) OnReceive 

func (mr *MockStreamReceiveListenerMockRecorder) OnReceive(ctx, headers, data, trailers interface{}) *gomock.Call

OnReceive indicates an expected call of OnReceive.

type MockStreamReceiverFilter 

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

MockStreamReceiverFilter is a mock of StreamReceiverFilter interface.

func NewMockStreamReceiverFilter 

func NewMockStreamReceiverFilter(ctrl *gomock.Controller) *MockStreamReceiverFilter

NewMockStreamReceiverFilter creates a new mock instance.

func (*MockStreamReceiverFilter) EXPECT 

func (m *MockStreamReceiverFilter) EXPECT() *MockStreamReceiverFilterMockRecorder

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

func (*MockStreamReceiverFilter) OnDestroy 

func (m *MockStreamReceiverFilter) OnDestroy()

OnDestroy mocks base method.

func (*MockStreamReceiverFilter) OnReceive 

func (m *MockStreamReceiverFilter) OnReceive(ctx context.Context, headers api.HeaderMap, buf api.IoBuffer, trailers api.HeaderMap) api.StreamFilterStatus

OnReceive mocks base method.

func (*MockStreamReceiverFilter) SetReceiveFilterHandler 

func (m *MockStreamReceiverFilter) SetReceiveFilterHandler(handler api.StreamReceiverFilterHandler)

SetReceiveFilterHandler mocks base method.

type MockStreamReceiverFilterHandler 

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

MockStreamReceiverFilterHandler is a mock of StreamReceiverFilterHandler interface.

func NewMockStreamReceiverFilterHandler 

func NewMockStreamReceiverFilterHandler(ctrl *gomock.Controller) *MockStreamReceiverFilterHandler

NewMockStreamReceiverFilterHandler creates a new mock instance.

func (*MockStreamReceiverFilterHandler) AppendData 

func (m *MockStreamReceiverFilterHandler) AppendData(buf api.IoBuffer, endStream bool)

AppendData mocks base method.

func (*MockStreamReceiverFilterHandler) AppendHeaders 

func (m *MockStreamReceiverFilterHandler) AppendHeaders(headers api.HeaderMap, endStream bool)

AppendHeaders mocks base method.

func (*MockStreamReceiverFilterHandler) AppendTrailers 

func (m *MockStreamReceiverFilterHandler) AppendTrailers(trailers api.HeaderMap)

AppendTrailers mocks base method.

func (*MockStreamReceiverFilterHandler) Connection 

func (m *MockStreamReceiverFilterHandler) Connection() api.Connection

Connection mocks base method.

func (*MockStreamReceiverFilterHandler) EXPECT 

func (m *MockStreamReceiverFilterHandler) EXPECT() *MockStreamReceiverFilterHandlerMockRecorder

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

func (*MockStreamReceiverFilterHandler) GetFilterCurrentPhase 

func (m *MockStreamReceiverFilterHandler) GetFilterCurrentPhase() api.ReceiverFilterPhase

GetFilterCurrentPhase mocks base method.

func (*MockStreamReceiverFilterHandler) GetRequestData 

func (m *MockStreamReceiverFilterHandler) GetRequestData() api.IoBuffer

GetRequestData mocks base method.

func (*MockStreamReceiverFilterHandler) GetRequestHeaders 

func (m *MockStreamReceiverFilterHandler) GetRequestHeaders() api.HeaderMap

GetRequestHeaders mocks base method.

func (*MockStreamReceiverFilterHandler) GetRequestTrailers 

func (m *MockStreamReceiverFilterHandler) GetRequestTrailers() api.HeaderMap

GetRequestTrailers mocks base method.

func (*MockStreamReceiverFilterHandler) RequestInfo 

func (m *MockStreamReceiverFilterHandler) RequestInfo() api.RequestInfo

RequestInfo mocks base method.

func (*MockStreamReceiverFilterHandler) Route 

func (m *MockStreamReceiverFilterHandler) Route() api.Route

Route mocks base method.

func (*MockStreamReceiverFilterHandler) SendDirectResponse 

func (m *MockStreamReceiverFilterHandler) SendDirectResponse(headers api.HeaderMap, buf api.IoBuffer, trailers api.HeaderMap)

SendDirectResponse mocks base method.

func (*MockStreamReceiverFilterHandler) SendHijackReply 

func (m *MockStreamReceiverFilterHandler) SendHijackReply(code int, headers api.HeaderMap)

SendHijackReply mocks base method.

func (*MockStreamReceiverFilterHandler) SendHijackReplyWithBody added in v0.19.0 

func (m *MockStreamReceiverFilterHandler) SendHijackReplyWithBody(code int, headers api.HeaderMap, body string)

SendHijackReplyWithBody mocks base method.

func (*MockStreamReceiverFilterHandler) SetRequestData 

func (m *MockStreamReceiverFilterHandler) SetRequestData(buf api.IoBuffer)

SetRequestData mocks base method.

func (*MockStreamReceiverFilterHandler) SetRequestHeaders 

func (m *MockStreamReceiverFilterHandler) SetRequestHeaders(headers api.HeaderMap)

SetRequestHeaders mocks base method.

func (*MockStreamReceiverFilterHandler) SetRequestTrailers 

func (m *MockStreamReceiverFilterHandler) SetRequestTrailers(trailers api.HeaderMap)

SetRequestTrailers mocks base method.

func (*MockStreamReceiverFilterHandler) TerminateStream added in v0.19.0 

func (m *MockStreamReceiverFilterHandler) TerminateStream(code int) bool

TerminateStream mocks base method.

type MockStreamReceiverFilterHandlerMockRecorder 

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

MockStreamReceiverFilterHandlerMockRecorder is the mock recorder for MockStreamReceiverFilterHandler.

func (*MockStreamReceiverFilterHandlerMockRecorder) AppendData 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) AppendData(buf, endStream interface{}) *gomock.Call

AppendData indicates an expected call of AppendData.

func (*MockStreamReceiverFilterHandlerMockRecorder) AppendHeaders 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) AppendHeaders(headers, endStream interface{}) *gomock.Call

AppendHeaders indicates an expected call of AppendHeaders.

func (*MockStreamReceiverFilterHandlerMockRecorder) AppendTrailers 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) AppendTrailers(trailers interface{}) *gomock.Call

AppendTrailers indicates an expected call of AppendTrailers.

func (*MockStreamReceiverFilterHandlerMockRecorder) Connection 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) Connection() *gomock.Call

Connection indicates an expected call of Connection.

func (*MockStreamReceiverFilterHandlerMockRecorder) GetFilterCurrentPhase 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) GetFilterCurrentPhase() *gomock.Call

GetFilterCurrentPhase indicates an expected call of GetFilterCurrentPhase.

func (*MockStreamReceiverFilterHandlerMockRecorder) GetRequestData 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) GetRequestData() *gomock.Call

GetRequestData indicates an expected call of GetRequestData.

func (*MockStreamReceiverFilterHandlerMockRecorder) GetRequestHeaders 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) GetRequestHeaders() *gomock.Call

GetRequestHeaders indicates an expected call of GetRequestHeaders.

func (*MockStreamReceiverFilterHandlerMockRecorder) GetRequestTrailers 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) GetRequestTrailers() *gomock.Call

GetRequestTrailers indicates an expected call of GetRequestTrailers.

func (*MockStreamReceiverFilterHandlerMockRecorder) RequestInfo 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) RequestInfo() *gomock.Call

RequestInfo indicates an expected call of RequestInfo.

func (*MockStreamReceiverFilterHandlerMockRecorder) Route 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) Route() *gomock.Call

Route indicates an expected call of Route.

func (*MockStreamReceiverFilterHandlerMockRecorder) SendDirectResponse 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) SendDirectResponse(headers, buf, trailers interface{}) *gomock.Call

SendDirectResponse indicates an expected call of SendDirectResponse.

func (*MockStreamReceiverFilterHandlerMockRecorder) SendHijackReply 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) SendHijackReply(code, headers interface{}) *gomock.Call

SendHijackReply indicates an expected call of SendHijackReply.

func (*MockStreamReceiverFilterHandlerMockRecorder) SendHijackReplyWithBody added in v0.19.0 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) SendHijackReplyWithBody(code, headers, body interface{}) *gomock.Call

SendHijackReplyWithBody indicates an expected call of SendHijackReplyWithBody.

func (*MockStreamReceiverFilterHandlerMockRecorder) SetRequestData 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) SetRequestData(buf interface{}) *gomock.Call

SetRequestData indicates an expected call of SetRequestData.

func (*MockStreamReceiverFilterHandlerMockRecorder) SetRequestHeaders 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) SetRequestHeaders(headers interface{}) *gomock.Call

SetRequestHeaders indicates an expected call of SetRequestHeaders.

func (*MockStreamReceiverFilterHandlerMockRecorder) SetRequestTrailers 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) SetRequestTrailers(trailers interface{}) *gomock.Call

SetRequestTrailers indicates an expected call of SetRequestTrailers.

func (*MockStreamReceiverFilterHandlerMockRecorder) TerminateStream added in v0.19.0 

func (mr *MockStreamReceiverFilterHandlerMockRecorder) TerminateStream(code interface{}) *gomock.Call

TerminateStream indicates an expected call of TerminateStream.

type MockStreamReceiverFilterMockRecorder 

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

MockStreamReceiverFilterMockRecorder is the mock recorder for MockStreamReceiverFilter.

func (*MockStreamReceiverFilterMockRecorder) OnDestroy 

func (mr *MockStreamReceiverFilterMockRecorder) OnDestroy() *gomock.Call

OnDestroy indicates an expected call of OnDestroy.

func (*MockStreamReceiverFilterMockRecorder) OnReceive 

func (mr *MockStreamReceiverFilterMockRecorder) OnReceive(ctx, headers, buf, trailers interface{}) *gomock.Call

OnReceive indicates an expected call of OnReceive.

func (*MockStreamReceiverFilterMockRecorder) SetReceiveFilterHandler 

func (mr *MockStreamReceiverFilterMockRecorder) SetReceiveFilterHandler(handler interface{}) *gomock.Call

SetReceiveFilterHandler indicates an expected call of SetReceiveFilterHandler.

type MockStreamSender 

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

MockStreamSender is a mock of StreamSender interface.

func NewMockStreamSender 

func NewMockStreamSender(ctrl *gomock.Controller) *MockStreamSender

NewMockStreamSender creates a new mock instance.

func (*MockStreamSender) AppendData 

func (m *MockStreamSender) AppendData(ctx context.Context, data buffer.IoBuffer, endStream bool) error

AppendData mocks base method.

func (*MockStreamSender) AppendHeaders 

func (m *MockStreamSender) AppendHeaders(ctx context.Context, headers api.HeaderMap, endStream bool) error

AppendHeaders mocks base method.

func (*MockStreamSender) AppendTrailers 

func (m *MockStreamSender) AppendTrailers(ctx context.Context, trailers api.HeaderMap) error

AppendTrailers mocks base method.

func (*MockStreamSender) EXPECT 

func (m *MockStreamSender) EXPECT() *MockStreamSenderMockRecorder

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

func (*MockStreamSender) GetStream 

func (m *MockStreamSender) GetStream() types.Stream

GetStream mocks base method.

type MockStreamSenderFilter 

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

MockStreamSenderFilter is a mock of StreamSenderFilter interface.

func NewMockStreamSenderFilter 

func NewMockStreamSenderFilter(ctrl *gomock.Controller) *MockStreamSenderFilter

NewMockStreamSenderFilter creates a new mock instance.

func (*MockStreamSenderFilter) Append 

func (m *MockStreamSenderFilter) Append(ctx context.Context, headers api.HeaderMap, buf api.IoBuffer, trailers api.HeaderMap) api.StreamFilterStatus

Append mocks base method.

func (*MockStreamSenderFilter) EXPECT 

func (m *MockStreamSenderFilter) EXPECT() *MockStreamSenderFilterMockRecorder

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

func (*MockStreamSenderFilter) OnDestroy 

func (m *MockStreamSenderFilter) OnDestroy()

OnDestroy mocks base method.

func (*MockStreamSenderFilter) SetSenderFilterHandler 

func (m *MockStreamSenderFilter) SetSenderFilterHandler(handler api.StreamSenderFilterHandler)

SetSenderFilterHandler mocks base method.

type MockStreamSenderFilterHandler 

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

MockStreamSenderFilterHandler is a mock of StreamSenderFilterHandler interface.

func NewMockStreamSenderFilterHandler 

func NewMockStreamSenderFilterHandler(ctrl *gomock.Controller) *MockStreamSenderFilterHandler

NewMockStreamSenderFilterHandler creates a new mock instance.

func (*MockStreamSenderFilterHandler) Connection 

func (m *MockStreamSenderFilterHandler) Connection() api.Connection

Connection mocks base method.

func (*MockStreamSenderFilterHandler) EXPECT 

func (m *MockStreamSenderFilterHandler) EXPECT() *MockStreamSenderFilterHandlerMockRecorder

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

func (*MockStreamSenderFilterHandler) GetResponseData 

func (m *MockStreamSenderFilterHandler) GetResponseData() api.IoBuffer

GetResponseData mocks base method.

func (*MockStreamSenderFilterHandler) GetResponseHeaders 

func (m *MockStreamSenderFilterHandler) GetResponseHeaders() api.HeaderMap

GetResponseHeaders mocks base method.

func (*MockStreamSenderFilterHandler) GetResponseTrailers 

func (m *MockStreamSenderFilterHandler) GetResponseTrailers() api.HeaderMap

GetResponseTrailers mocks base method.

func (*MockStreamSenderFilterHandler) RequestInfo 

func (m *MockStreamSenderFilterHandler) RequestInfo() api.RequestInfo

RequestInfo mocks base method.

func (*MockStreamSenderFilterHandler) Route 

func (m *MockStreamSenderFilterHandler) Route() api.Route

Route mocks base method.

func (*MockStreamSenderFilterHandler) SetResponseData 

func (m *MockStreamSenderFilterHandler) SetResponseData(buf api.IoBuffer)

SetResponseData mocks base method.

func (*MockStreamSenderFilterHandler) SetResponseHeaders 

func (m *MockStreamSenderFilterHandler) SetResponseHeaders(headers api.HeaderMap)

SetResponseHeaders mocks base method.

func (*MockStreamSenderFilterHandler) SetResponseTrailers 

func (m *MockStreamSenderFilterHandler) SetResponseTrailers(trailers api.HeaderMap)

SetResponseTrailers mocks base method.

type MockStreamSenderFilterHandlerMockRecorder 

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

MockStreamSenderFilterHandlerMockRecorder is the mock recorder for MockStreamSenderFilterHandler.

func (*MockStreamSenderFilterHandlerMockRecorder) Connection 

func (mr *MockStreamSenderFilterHandlerMockRecorder) Connection() *gomock.Call

Connection indicates an expected call of Connection.

func (*MockStreamSenderFilterHandlerMockRecorder) GetResponseData 

func (mr *MockStreamSenderFilterHandlerMockRecorder) GetResponseData() *gomock.Call

GetResponseData indicates an expected call of GetResponseData.

func (*MockStreamSenderFilterHandlerMockRecorder) GetResponseHeaders 

func (mr *MockStreamSenderFilterHandlerMockRecorder) GetResponseHeaders() *gomock.Call

GetResponseHeaders indicates an expected call of GetResponseHeaders.

func (*MockStreamSenderFilterHandlerMockRecorder) GetResponseTrailers 

func (mr *MockStreamSenderFilterHandlerMockRecorder) GetResponseTrailers() *gomock.Call

GetResponseTrailers indicates an expected call of GetResponseTrailers.

func (*MockStreamSenderFilterHandlerMockRecorder) RequestInfo 

func (mr *MockStreamSenderFilterHandlerMockRecorder) RequestInfo() *gomock.Call

RequestInfo indicates an expected call of RequestInfo.

func (*MockStreamSenderFilterHandlerMockRecorder) Route 

func (mr *MockStreamSenderFilterHandlerMockRecorder) Route() *gomock.Call

Route indicates an expected call of Route.

func (*MockStreamSenderFilterHandlerMockRecorder) SetResponseData 

func (mr *MockStreamSenderFilterHandlerMockRecorder) SetResponseData(buf interface{}) *gomock.Call

SetResponseData indicates an expected call of SetResponseData.

func (*MockStreamSenderFilterHandlerMockRecorder) SetResponseHeaders 

func (mr *MockStreamSenderFilterHandlerMockRecorder) SetResponseHeaders(headers interface{}) *gomock.Call

SetResponseHeaders indicates an expected call of SetResponseHeaders.

func (*MockStreamSenderFilterHandlerMockRecorder) SetResponseTrailers 

func (mr *MockStreamSenderFilterHandlerMockRecorder) SetResponseTrailers(trailers interface{}) *gomock.Call

SetResponseTrailers indicates an expected call of SetResponseTrailers.

type MockStreamSenderFilterMockRecorder 

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

MockStreamSenderFilterMockRecorder is the mock recorder for MockStreamSenderFilter.

func (*MockStreamSenderFilterMockRecorder) Append 

func (mr *MockStreamSenderFilterMockRecorder) Append(ctx, headers, buf, trailers interface{}) *gomock.Call

Append indicates an expected call of Append.

func (*MockStreamSenderFilterMockRecorder) OnDestroy 

func (mr *MockStreamSenderFilterMockRecorder) OnDestroy() *gomock.Call

OnDestroy indicates an expected call of OnDestroy.

func (*MockStreamSenderFilterMockRecorder) SetSenderFilterHandler 

func (mr *MockStreamSenderFilterMockRecorder) SetSenderFilterHandler(handler interface{}) *gomock.Call

SetSenderFilterHandler indicates an expected call of SetSenderFilterHandler.

type MockStreamSenderMockRecorder 

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

MockStreamSenderMockRecorder is the mock recorder for MockStreamSender.

func (*MockStreamSenderMockRecorder) AppendData 

func (mr *MockStreamSenderMockRecorder) AppendData(ctx, data, endStream interface{}) *gomock.Call

AppendData indicates an expected call of AppendData.

func (*MockStreamSenderMockRecorder) AppendHeaders 

func (mr *MockStreamSenderMockRecorder) AppendHeaders(ctx, headers, endStream interface{}) *gomock.Call

AppendHeaders indicates an expected call of AppendHeaders.

func (*MockStreamSenderMockRecorder) AppendTrailers 

func (mr *MockStreamSenderMockRecorder) AppendTrailers(ctx, trailers interface{}) *gomock.Call

AppendTrailers indicates an expected call of AppendTrailers.

func (*MockStreamSenderMockRecorder) GetStream 

func (mr *MockStreamSenderMockRecorder) GetStream() *gomock.Call

GetStream indicates an expected call of GetStream.

type MockTLSClientContextManager added in v0.27.0 

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

MockTLSClientContextManager is a mock of TLSClientContextManager interface.

func NewMockTLSClientContextManager added in v0.27.0 

func NewMockTLSClientContextManager(ctrl *gomock.Controller) *MockTLSClientContextManager

NewMockTLSClientContextManager creates a new mock instance.

func (*MockTLSClientContextManager) Conn added in v0.27.0 

func (m *MockTLSClientContextManager) Conn(arg0 net.Conn) (net.Conn, error)

Conn mocks base method.

func (*MockTLSClientContextManager) EXPECT added in v0.27.0 

func (m *MockTLSClientContextManager) EXPECT() *MockTLSClientContextManagerMockRecorder

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

func (*MockTLSClientContextManager) Enabled added in v0.27.0 

func (m *MockTLSClientContextManager) Enabled() bool

Enabled mocks base method.

func (*MockTLSClientContextManager) Fallback added in v0.27.0 

func (m *MockTLSClientContextManager) Fallback() bool

Fallback mocks base method.

func (*MockTLSClientContextManager) HashValue added in v0.27.0 

func (m *MockTLSClientContextManager) HashValue() *types.HashValue

HashValue mocks base method.

type MockTLSClientContextManagerMockRecorder added in v0.27.0 

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

MockTLSClientContextManagerMockRecorder is the mock recorder for MockTLSClientContextManager.

func (*MockTLSClientContextManagerMockRecorder) Conn added in v0.27.0 

func (mr *MockTLSClientContextManagerMockRecorder) Conn(arg0 interface{}) *gomock.Call

Conn indicates an expected call of Conn.

func (*MockTLSClientContextManagerMockRecorder) Enabled added in v0.27.0 

func (mr *MockTLSClientContextManagerMockRecorder) Enabled() *gomock.Call

Enabled indicates an expected call of Enabled.

func (*MockTLSClientContextManagerMockRecorder) Fallback added in v0.27.0 

func (mr *MockTLSClientContextManagerMockRecorder) Fallback() *gomock.Call

Fallback indicates an expected call of Fallback.

func (*MockTLSClientContextManagerMockRecorder) HashValue added in v0.27.0 

func (mr *MockTLSClientContextManagerMockRecorder) HashValue() *gomock.Call

HashValue indicates an expected call of HashValue.

type MockTLSContextManager added in v0.27.0 

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

MockTLSContextManager is a mock of TLSContextManager interface.

func NewMockTLSContextManager added in v0.27.0 

func NewMockTLSContextManager(ctrl *gomock.Controller) *MockTLSContextManager

NewMockTLSContextManager creates a new mock instance.

func (*MockTLSContextManager) Conn added in v0.27.0 

func (m *MockTLSContextManager) Conn(arg0 net.Conn) (net.Conn, error)

Conn mocks base method.

func (*MockTLSContextManager) EXPECT added in v0.27.0 

func (m *MockTLSContextManager) EXPECT() *MockTLSContextManagerMockRecorder

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

func (*MockTLSContextManager) Enabled added in v0.27.0 

func (m *MockTLSContextManager) Enabled() bool

Enabled mocks base method.

type MockTLSContextManagerMockRecorder added in v0.27.0 

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

MockTLSContextManagerMockRecorder is the mock recorder for MockTLSContextManager.

func (*MockTLSContextManagerMockRecorder) Conn added in v0.27.0 

func (mr *MockTLSContextManagerMockRecorder) Conn(arg0 interface{}) *gomock.Call

Conn indicates an expected call of Conn.

func (*MockTLSContextManagerMockRecorder) Enabled added in v0.27.0 

func (mr *MockTLSContextManagerMockRecorder) Enabled() *gomock.Call

Enabled indicates an expected call of Enabled.

type MockTLSProvider added in v0.27.0 

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

MockTLSProvider is a mock of TLSProvider interface.

func NewMockTLSProvider added in v0.27.0 

func NewMockTLSProvider(ctrl *gomock.Controller) *MockTLSProvider

NewMockTLSProvider creates a new mock instance.

func (*MockTLSProvider) EXPECT added in v0.27.0 

func (m *MockTLSProvider) EXPECT() *MockTLSProviderMockRecorder

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

func (*MockTLSProvider) Empty added in v0.27.0 

func (m *MockTLSProvider) Empty() bool

Empty mocks base method.

func (*MockTLSProvider) GetTLSConfigContext added in v0.27.0 

func (m *MockTLSProvider) GetTLSConfigContext(client bool) *types.TLSConfigContext

GetTLSConfigContext mocks base method.

func (*MockTLSProvider) MatchedALPN added in v0.27.0 

func (m *MockTLSProvider) MatchedALPN(protos []string) bool

MatchedALPN mocks base method.

func (*MockTLSProvider) MatchedServerName added in v0.27.0 

func (m *MockTLSProvider) MatchedServerName(sn string) bool

MatchedServerName mocks base method.

func (*MockTLSProvider) Ready added in v0.27.0 

func (m *MockTLSProvider) Ready() bool

Ready mocks base method.

type MockTLSProviderMockRecorder added in v0.27.0 

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

MockTLSProviderMockRecorder is the mock recorder for MockTLSProvider.

func (*MockTLSProviderMockRecorder) Empty added in v0.27.0 

func (mr *MockTLSProviderMockRecorder) Empty() *gomock.Call

Empty indicates an expected call of Empty.

func (*MockTLSProviderMockRecorder) GetTLSConfigContext added in v0.27.0 

func (mr *MockTLSProviderMockRecorder) GetTLSConfigContext(client interface{}) *gomock.Call

GetTLSConfigContext indicates an expected call of GetTLSConfigContext.

func (*MockTLSProviderMockRecorder) MatchedALPN added in v0.27.0 

func (mr *MockTLSProviderMockRecorder) MatchedALPN(protos interface{}) *gomock.Call

MatchedALPN indicates an expected call of MatchedALPN.

func (*MockTLSProviderMockRecorder) MatchedServerName added in v0.27.0 

func (mr *MockTLSProviderMockRecorder) MatchedServerName(sn interface{}) *gomock.Call

MatchedServerName indicates an expected call of MatchedServerName.

func (*MockTLSProviderMockRecorder) Ready added in v0.27.0 

func (mr *MockTLSProviderMockRecorder) Ready() *gomock.Call

Ready indicates an expected call of Ready.

type MockTlsContext added in v0.27.0 

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

MockTlsContext is a mock of TlsContext interface.

func NewMockTlsContext added in v0.27.0 

func NewMockTlsContext(ctrl *gomock.Controller) *MockTlsContext

NewMockTlsContext creates a new mock instance.

func (*MockTlsContext) EXPECT added in v0.27.0 

func (m *MockTlsContext) EXPECT() *MockTlsContextMockRecorder

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

func (*MockTlsContext) GetClientTLSConfigContext added in v0.27.0 

func (m *MockTlsContext) GetClientTLSConfigContext() *types.TLSConfigContext

GetClientTLSConfigContext mocks base method.

func (*MockTlsContext) GetSecretInfo added in v0.27.0 

func (m *MockTlsContext) GetSecretInfo() *mtls.SecretInfo

GetSecretInfo mocks base method.

func (*MockTlsContext) GetServerTLSConfigContext added in v0.27.0 

func (m *MockTlsContext) GetServerTLSConfigContext() *types.TLSConfigContext

GetServerTLSConfigContext mocks base method.

func (*MockTlsContext) GetTLSConfig added in v0.27.0 

func (m *MockTlsContext) GetTLSConfig() *v2.TLSConfig

GetTLSConfig mocks base method.

func (*MockTlsContext) MatchedALPN added in v0.27.0 

func (m *MockTlsContext) MatchedALPN(protocols []string) bool

MatchedALPN mocks base method.

func (*MockTlsContext) MatchedServerName added in v0.27.0 

func (m *MockTlsContext) MatchedServerName(sn string) bool

MatchedServerName mocks base method.

func (*MockTlsContext) SetClientConfig added in v0.27.0 

func (m *MockTlsContext) SetClientConfig(template *tls.Config, cfg *v2.TLSConfig, hooks mtls.ConfigHooks)

SetClientConfig mocks base method.

func (*MockTlsContext) SetServerConfig added in v0.27.0 

func (m *MockTlsContext) SetServerConfig(template *tls.Config, cfg *v2.TLSConfig, hooks mtls.ConfigHooks)

SetServerConfig mocks base method.

type MockTlsContextMockRecorder added in v0.27.0 

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

MockTlsContextMockRecorder is the mock recorder for MockTlsContext.

func (*MockTlsContextMockRecorder) GetClientTLSConfigContext added in v0.27.0 

func (mr *MockTlsContextMockRecorder) GetClientTLSConfigContext() *gomock.Call

GetClientTLSConfigContext indicates an expected call of GetClientTLSConfigContext.

func (*MockTlsContextMockRecorder) GetSecretInfo added in v0.27.0 

func (mr *MockTlsContextMockRecorder) GetSecretInfo() *gomock.Call

GetSecretInfo indicates an expected call of GetSecretInfo.

func (*MockTlsContextMockRecorder) GetServerTLSConfigContext added in v0.27.0 

func (mr *MockTlsContextMockRecorder) GetServerTLSConfigContext() *gomock.Call

GetServerTLSConfigContext indicates an expected call of GetServerTLSConfigContext.

func (*MockTlsContextMockRecorder) GetTLSConfig added in v0.27.0 

func (mr *MockTlsContextMockRecorder) GetTLSConfig() *gomock.Call

GetTLSConfig indicates an expected call of GetTLSConfig.

func (*MockTlsContextMockRecorder) MatchedALPN added in v0.27.0 

func (mr *MockTlsContextMockRecorder) MatchedALPN(protocols interface{}) *gomock.Call

MatchedALPN indicates an expected call of MatchedALPN.

func (*MockTlsContextMockRecorder) MatchedServerName added in v0.27.0 

func (mr *MockTlsContextMockRecorder) MatchedServerName(sn interface{}) *gomock.Call

MatchedServerName indicates an expected call of MatchedServerName.

func (*MockTlsContextMockRecorder) SetClientConfig added in v0.27.0 

func (mr *MockTlsContextMockRecorder) SetClientConfig(template, cfg, hooks interface{}) *gomock.Call

SetClientConfig indicates an expected call of SetClientConfig.

func (*MockTlsContextMockRecorder) SetServerConfig added in v0.27.0 

func (mr *MockTlsContextMockRecorder) SetServerConfig(template, cfg, hooks interface{}) *gomock.Call

SetServerConfig indicates an expected call of SetServerConfig.

type MockTracer 

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

MockTracer is a mock of Tracer interface.

func NewMockTracer 

func NewMockTracer(ctrl *gomock.Controller) *MockTracer

NewMockTracer creates a new mock instance.

func (*MockTracer) EXPECT 

func (m *MockTracer) EXPECT() *MockTracerMockRecorder

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

func (*MockTracer) Start 

func (m *MockTracer) Start(ctx context.Context, request interface{}, startTime time.Time) api.Span

Start mocks base method.

type MockTracerMockRecorder 

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

MockTracerMockRecorder is the mock recorder for MockTracer.

func (*MockTracerMockRecorder) Start 

func (mr *MockTracerMockRecorder) Start(ctx, request, startTime interface{}) *gomock.Call

Start indicates an expected call of Start.

type MockVirtualHost 

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

MockVirtualHost is a mock of VirtualHost interface.

func NewMockVirtualHost 

func NewMockVirtualHost(ctrl *gomock.Controller) *MockVirtualHost

NewMockVirtualHost creates a new mock instance.

func (*MockVirtualHost) AddRoute 

func (m *MockVirtualHost) AddRoute(route api.RouteBase) error

AddRoute mocks base method.

func (*MockVirtualHost) EXPECT 

func (m *MockVirtualHost) EXPECT() *MockVirtualHostMockRecorder

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

func (*MockVirtualHost) FinalizeRequestHeaders added in v0.21.0 

func (m *MockVirtualHost) FinalizeRequestHeaders(ctx context.Context, headers api.HeaderMap, requestInfo api.RequestInfo)

FinalizeRequestHeaders mocks base method.

func (*MockVirtualHost) FinalizeResponseHeaders added in v0.21.0 

func (m *MockVirtualHost) FinalizeResponseHeaders(ctx context.Context, headers api.HeaderMap, requestInfo api.RequestInfo)

FinalizeResponseHeaders mocks base method.

func (*MockVirtualHost) GetAllRoutesFromEntries 

func (m *MockVirtualHost) GetAllRoutesFromEntries(ctx context.Context, headers api.HeaderMap) []api.Route

GetAllRoutesFromEntries mocks base method.

func (*MockVirtualHost) GetRouteFromEntries 

func (m *MockVirtualHost) GetRouteFromEntries(ctx context.Context, headers api.HeaderMap) api.Route

GetRouteFromEntries mocks base method.

func (*MockVirtualHost) GetRouteFromHeaderKV 

func (m *MockVirtualHost) GetRouteFromHeaderKV(key, value string) api.Route

GetRouteFromHeaderKV mocks base method.

func (*MockVirtualHost) Name 

func (m *MockVirtualHost) Name() string

Name mocks base method.

func (*MockVirtualHost) PerFilterConfig added in v0.21.0 

func (m *MockVirtualHost) PerFilterConfig() map[string]interface{}

PerFilterConfig mocks base method.

func (*MockVirtualHost) RemoveAllRoutes 

func (m *MockVirtualHost) RemoveAllRoutes()

RemoveAllRoutes mocks base method.

type MockVirtualHostMockRecorder 

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

MockVirtualHostMockRecorder is the mock recorder for MockVirtualHost.

func (*MockVirtualHostMockRecorder) AddRoute 

func (mr *MockVirtualHostMockRecorder) AddRoute(route interface{}) *gomock.Call

AddRoute indicates an expected call of AddRoute.

func (*MockVirtualHostMockRecorder) FinalizeRequestHeaders added in v0.21.0 

func (mr *MockVirtualHostMockRecorder) FinalizeRequestHeaders(ctx, headers, requestInfo interface{}) *gomock.Call

FinalizeRequestHeaders indicates an expected call of FinalizeRequestHeaders.

func (*MockVirtualHostMockRecorder) FinalizeResponseHeaders added in v0.21.0 

func (mr *MockVirtualHostMockRecorder) FinalizeResponseHeaders(ctx, headers, requestInfo interface{}) *gomock.Call

FinalizeResponseHeaders indicates an expected call of FinalizeResponseHeaders.

func (*MockVirtualHostMockRecorder) GetAllRoutesFromEntries 

func (mr *MockVirtualHostMockRecorder) GetAllRoutesFromEntries(ctx, headers interface{}) *gomock.Call

GetAllRoutesFromEntries indicates an expected call of GetAllRoutesFromEntries.

func (*MockVirtualHostMockRecorder) GetRouteFromEntries 

func (mr *MockVirtualHostMockRecorder) GetRouteFromEntries(ctx, headers interface{}) *gomock.Call

GetRouteFromEntries indicates an expected call of GetRouteFromEntries.

func (*MockVirtualHostMockRecorder) GetRouteFromHeaderKV 

func (mr *MockVirtualHostMockRecorder) GetRouteFromHeaderKV(key, value interface{}) *gomock.Call

GetRouteFromHeaderKV indicates an expected call of GetRouteFromHeaderKV.

func (*MockVirtualHostMockRecorder) Name 

func (mr *MockVirtualHostMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockVirtualHostMockRecorder) PerFilterConfig added in v0.21.0 

func (mr *MockVirtualHostMockRecorder) PerFilterConfig() *gomock.Call

PerFilterConfig indicates an expected call of PerFilterConfig.

func (*MockVirtualHostMockRecorder) RemoveAllRoutes 

func (mr *MockVirtualHostMockRecorder) RemoveAllRoutes() *gomock.Call

RemoveAllRoutes indicates an expected call of RemoveAllRoutes.

type MockWasmFunction added in v0.22.0 

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

MockWasmFunction is a mock of WasmFunction interface.

func NewMockWasmFunction added in v0.22.0 

func NewMockWasmFunction(ctrl *gomock.Controller) *MockWasmFunction

NewMockWasmFunction creates a new mock instance.

func (*MockWasmFunction) Call added in v0.22.0 

func (m *MockWasmFunction) Call(arg0 ...interface{}) (interface{}, error)

Call mocks base method.

func (*MockWasmFunction) EXPECT added in v0.22.0 

func (m *MockWasmFunction) EXPECT() *MockWasmFunctionMockRecorder

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

type MockWasmFunctionMockRecorder added in v0.22.0 

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

MockWasmFunctionMockRecorder is the mock recorder for MockWasmFunction.

func (*MockWasmFunctionMockRecorder) Call added in v0.22.0 

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

Call indicates an expected call of Call.

type MockWasmInstance added in v0.22.0 

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

MockWasmInstance is a mock of WasmInstance interface.

func NewMockWasmInstance added in v0.22.0 

func NewMockWasmInstance(ctrl *gomock.Controller) *MockWasmInstance

NewMockWasmInstance creates a new mock instance.

func (*MockWasmInstance) Acquire added in v0.22.0 

func (m *MockWasmInstance) Acquire() bool

Acquire mocks base method.

func (*MockWasmInstance) EXPECT added in v0.22.0 

func (m *MockWasmInstance) EXPECT() *MockWasmInstanceMockRecorder

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

func (*MockWasmInstance) GetByte added in v0.22.0 

func (m *MockWasmInstance) GetByte(arg0 uint64) (byte, error)

GetByte mocks base method.

func (*MockWasmInstance) GetData added in v0.22.0 

func (m *MockWasmInstance) GetData() interface{}

GetData mocks base method.

func (*MockWasmInstance) GetExportsFunc added in v0.22.0 

func (m *MockWasmInstance) GetExportsFunc(arg0 string) (common.WasmFunction, error)

GetExportsFunc mocks base method.

func (*MockWasmInstance) GetExportsMem added in v0.22.0 

func (m *MockWasmInstance) GetExportsMem(arg0 string) ([]byte, error)

GetExportsMem mocks base method.

func (*MockWasmInstance) GetMemory added in v0.22.0 

func (m *MockWasmInstance) GetMemory(arg0, arg1 uint64) ([]byte, error)

GetMemory mocks base method.

func (*MockWasmInstance) GetModule added in v0.22.0 

func (m *MockWasmInstance) GetModule() common.WasmModule

GetModule mocks base method.

func (*MockWasmInstance) GetUint32 added in v0.22.0 

func (m *MockWasmInstance) GetUint32(arg0 uint64) (uint32, error)

GetUint32 mocks base method.

func (*MockWasmInstance) HandleError added in v0.22.0 

func (m *MockWasmInstance) HandleError(arg0 error)

HandleError mocks base method.

func (*MockWasmInstance) Lock added in v0.22.0 

func (m *MockWasmInstance) Lock(arg0 interface{})

Lock mocks base method.

func (*MockWasmInstance) Malloc added in v0.22.0 

func (m *MockWasmInstance) Malloc(arg0 int32) (uint64, error)

Malloc mocks base method.

func (*MockWasmInstance) PutByte added in v0.22.0 

func (m *MockWasmInstance) PutByte(arg0 uint64, arg1 byte) error

PutByte mocks base method.

func (*MockWasmInstance) PutMemory added in v0.22.0 

func (m *MockWasmInstance) PutMemory(arg0, arg1 uint64, arg2 []byte) error

PutMemory mocks base method.

func (*MockWasmInstance) PutUint32 added in v0.22.0 

func (m *MockWasmInstance) PutUint32(arg0 uint64, arg1 uint32) error

PutUint32 mocks base method.

func (*MockWasmInstance) RegisterImports added in v1.3.0 

func (m *MockWasmInstance) RegisterImports(arg0 string) error

RegisterFunc mocks base method.

func (*MockWasmInstance) Release added in v0.22.0 

func (m *MockWasmInstance) Release()

Release mocks base method.

func (*MockWasmInstance) SetData added in v0.22.0 

func (m *MockWasmInstance) SetData(arg0 interface{})

SetData mocks base method.

func (*MockWasmInstance) Start added in v0.22.0 

func (m *MockWasmInstance) Start() error

Start mocks base method.

func (*MockWasmInstance) Stop added in v0.22.0 

func (m *MockWasmInstance) Stop()

Stop mocks base method.

func (*MockWasmInstance) Unlock added in v0.22.0 

func (m *MockWasmInstance) Unlock()

Unlock mocks base method.

type MockWasmInstanceMockRecorder added in v0.22.0 

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

MockWasmInstanceMockRecorder is the mock recorder for MockWasmInstance.

func (*MockWasmInstanceMockRecorder) Acquire added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Acquire() *gomock.Call

Acquire indicates an expected call of Acquire.

func (*MockWasmInstanceMockRecorder) GetByte added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetByte(arg0 interface{}) *gomock.Call

GetByte indicates an expected call of GetByte.

func (*MockWasmInstanceMockRecorder) GetData added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetData() *gomock.Call

GetData indicates an expected call of GetData.

func (*MockWasmInstanceMockRecorder) GetExportsFunc added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetExportsFunc(arg0 interface{}) *gomock.Call

GetExportsFunc indicates an expected call of GetExportsFunc.

func (*MockWasmInstanceMockRecorder) GetExportsMem added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetExportsMem(arg0 interface{}) *gomock.Call

GetExportsMem indicates an expected call of GetExportsMem.

func (*MockWasmInstanceMockRecorder) GetMemory added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetMemory(arg0, arg1 interface{}) *gomock.Call

GetMemory indicates an expected call of GetMemory.

func (*MockWasmInstanceMockRecorder) GetModule added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetModule() *gomock.Call

GetModule indicates an expected call of GetModule.

func (*MockWasmInstanceMockRecorder) GetUint32 added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) GetUint32(arg0 interface{}) *gomock.Call

GetUint32 indicates an expected call of GetUint32.

func (*MockWasmInstanceMockRecorder) HandleError added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) HandleError(arg0 interface{}) *gomock.Call

HandleError indicates an expected call of HandleError.

func (*MockWasmInstanceMockRecorder) Lock added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Lock(arg0 interface{}) *gomock.Call

Lock indicates an expected call of Lock.

func (*MockWasmInstanceMockRecorder) Malloc added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Malloc(arg0 interface{}) *gomock.Call

Malloc indicates an expected call of Malloc.

func (*MockWasmInstanceMockRecorder) PutByte added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) PutByte(arg0, arg1 interface{}) *gomock.Call

PutByte indicates an expected call of PutByte.

func (*MockWasmInstanceMockRecorder) PutMemory added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) PutMemory(arg0, arg1, arg2 interface{}) *gomock.Call

PutMemory indicates an expected call of PutMemory.

func (*MockWasmInstanceMockRecorder) PutUint32 added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) PutUint32(arg0, arg1 interface{}) *gomock.Call

PutUint32 indicates an expected call of PutUint32.

func (*MockWasmInstanceMockRecorder) RegisterImports added in v1.3.0 

func (mr *MockWasmInstanceMockRecorder) RegisterImports(arg0 interface{}) *gomock.Call

RegisterImports indicates an expected call of RegisterImports.

func (*MockWasmInstanceMockRecorder) Release added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Release() *gomock.Call

Release indicates an expected call of Release.

func (*MockWasmInstanceMockRecorder) SetData added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) SetData(arg0 interface{}) *gomock.Call

SetData indicates an expected call of SetData.

func (*MockWasmInstanceMockRecorder) Start added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Start() *gomock.Call

Start indicates an expected call of Start.

func (*MockWasmInstanceMockRecorder) Stop added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Stop() *gomock.Call

Stop indicates an expected call of Stop.

func (*MockWasmInstanceMockRecorder) Unlock added in v0.22.0 

func (mr *MockWasmInstanceMockRecorder) Unlock() *gomock.Call

Unlock indicates an expected call of Unlock.

type MockWasmManager added in v0.22.0 

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

MockWasmManager is a mock of WasmManager interface.

func NewMockWasmManager added in v0.22.0 

func NewMockWasmManager(ctrl *gomock.Controller) *MockWasmManager

NewMockWasmManager creates a new mock instance.

func (*MockWasmManager) AddOrUpdateWasm added in v0.22.0 

func (m *MockWasmManager) AddOrUpdateWasm(arg0 v2.WasmPluginConfig) error

AddOrUpdateWasm mocks base method.

func (*MockWasmManager) EXPECT added in v0.22.0 

func (m *MockWasmManager) EXPECT() *MockWasmManagerMockRecorder

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

func (*MockWasmManager) GetWasmPluginWrapperByName added in v0.22.0 

func (m *MockWasmManager) GetWasmPluginWrapperByName(arg0 string) types.WasmPluginWrapper

GetWasmPluginWrapperByName mocks base method.

func (*MockWasmManager) UninstallWasmPluginByName added in v0.22.0 

func (m *MockWasmManager) UninstallWasmPluginByName(arg0 string) error

UninstallWasmPluginByName mocks base method.

type MockWasmManagerMockRecorder added in v0.22.0 

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

MockWasmManagerMockRecorder is the mock recorder for MockWasmManager.

func (*MockWasmManagerMockRecorder) AddOrUpdateWasm added in v0.22.0 

func (mr *MockWasmManagerMockRecorder) AddOrUpdateWasm(arg0 interface{}) *gomock.Call

AddOrUpdateWasm indicates an expected call of AddOrUpdateWasm.

func (*MockWasmManagerMockRecorder) GetWasmPluginWrapperByName added in v0.22.0 

func (mr *MockWasmManagerMockRecorder) GetWasmPluginWrapperByName(arg0 interface{}) *gomock.Call

GetWasmPluginWrapperByName indicates an expected call of GetWasmPluginWrapperByName.

func (*MockWasmManagerMockRecorder) UninstallWasmPluginByName added in v0.22.0 

func (mr *MockWasmManagerMockRecorder) UninstallWasmPluginByName(arg0 interface{}) *gomock.Call

UninstallWasmPluginByName indicates an expected call of UninstallWasmPluginByName.

type MockWasmModule added in v0.22.0 

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

MockWasmModule is a mock of WasmModule interface.

func NewMockWasmModule added in v0.22.0 

func NewMockWasmModule(ctrl *gomock.Controller) *MockWasmModule

NewMockWasmModule creates a new mock instance.

func (*MockWasmModule) EXPECT added in v0.22.0 

func (m *MockWasmModule) EXPECT() *MockWasmModuleMockRecorder

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

func (*MockWasmModule) GetABINameList added in v0.22.0 

func (m *MockWasmModule) GetABINameList() []string

GetABINameList mocks base method.

func (*MockWasmModule) Init added in v0.22.0 

func (m *MockWasmModule) Init()

Init mocks base method.

func (*MockWasmModule) NewInstance added in v0.22.0 

func (m *MockWasmModule) NewInstance() common.WasmInstance

NewInstance mocks base method.

type MockWasmModuleMockRecorder added in v0.22.0 

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

MockWasmModuleMockRecorder is the mock recorder for MockWasmModule.

func (*MockWasmModuleMockRecorder) GetABINameList added in v0.22.0 

func (mr *MockWasmModuleMockRecorder) GetABINameList() *gomock.Call

GetABINameList indicates an expected call of GetABINameList.

func (*MockWasmModuleMockRecorder) Init added in v0.22.0 

func (mr *MockWasmModuleMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockWasmModuleMockRecorder) NewInstance added in v0.22.0 

func (mr *MockWasmModuleMockRecorder) NewInstance() *gomock.Call

NewInstance indicates an expected call of NewInstance.

type MockWasmPlugin added in v0.22.0 

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

MockWasmPlugin is a mock of WasmPlugin interface.

func NewMockWasmPlugin added in v0.22.0 

func NewMockWasmPlugin(ctrl *gomock.Controller) *MockWasmPlugin

NewMockWasmPlugin creates a new mock instance.

func (*MockWasmPlugin) Clear added in v0.22.0 

func (m *MockWasmPlugin) Clear()

Clear mocks base method.

func (*MockWasmPlugin) EXPECT added in v0.22.0 

func (m *MockWasmPlugin) EXPECT() *MockWasmPluginMockRecorder

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

func (*MockWasmPlugin) EnsureInstanceNum added in v0.22.0 

func (m *MockWasmPlugin) EnsureInstanceNum(arg0 int) int

EnsureInstanceNum mocks base method.

func (*MockWasmPlugin) Exec added in v0.22.0 

func (m *MockWasmPlugin) Exec(arg0 func(common.WasmInstance) bool)

Exec mocks base method.

func (*MockWasmPlugin) GetInstance added in v0.22.0 

func (m *MockWasmPlugin) GetInstance() common.WasmInstance

GetInstance mocks base method.

func (*MockWasmPlugin) GetPluginConfig added in v0.22.0 

func (m *MockWasmPlugin) GetPluginConfig() v2.WasmPluginConfig

GetPluginConfig mocks base method.

func (*MockWasmPlugin) GetVmConfig added in v0.22.0 

func (m *MockWasmPlugin) GetVmConfig() v2.WasmVmConfig

GetVmConfig mocks base method.

func (*MockWasmPlugin) InstanceNum added in v0.22.0 

func (m *MockWasmPlugin) InstanceNum() int

InstanceNum mocks base method.

func (*MockWasmPlugin) PluginName added in v0.22.0 

func (m *MockWasmPlugin) PluginName() string

PluginName mocks base method.

func (*MockWasmPlugin) ReleaseInstance added in v0.22.0 

func (m *MockWasmPlugin) ReleaseInstance(arg0 common.WasmInstance)

ReleaseInstance mocks base method.

func (*MockWasmPlugin) SetCpuLimit added in v0.22.0 

func (m *MockWasmPlugin) SetCpuLimit(arg0 int)

SetCpuLimit mocks base method.

func (*MockWasmPlugin) SetMemLimit added in v0.22.0 

func (m *MockWasmPlugin) SetMemLimit(arg0 int)

SetMemLimit mocks base method.

type MockWasmPluginHandler added in v0.22.0 

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

MockWasmPluginHandler is a mock of WasmPluginHandler interface.

func NewMockWasmPluginHandler added in v0.22.0 

func NewMockWasmPluginHandler(ctrl *gomock.Controller) *MockWasmPluginHandler

NewMockWasmPluginHandler creates a new mock instance.

func (*MockWasmPluginHandler) EXPECT added in v0.22.0 

func (m *MockWasmPluginHandler) EXPECT() *MockWasmPluginHandlerMockRecorder

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

func (*MockWasmPluginHandler) OnConfigUpdate added in v0.22.0 

func (m *MockWasmPluginHandler) OnConfigUpdate(arg0 v2.WasmPluginConfig)

OnConfigUpdate mocks base method.

func (*MockWasmPluginHandler) OnPluginDestroy added in v0.22.0 

func (m *MockWasmPluginHandler) OnPluginDestroy(arg0 types.WasmPlugin)

OnPluginDestroy mocks base method.

func (*MockWasmPluginHandler) OnPluginStart added in v0.22.0 

func (m *MockWasmPluginHandler) OnPluginStart(arg0 types.WasmPlugin)

OnPluginStart mocks base method.

type MockWasmPluginHandlerMockRecorder added in v0.22.0 

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

MockWasmPluginHandlerMockRecorder is the mock recorder for MockWasmPluginHandler.

func (*MockWasmPluginHandlerMockRecorder) OnConfigUpdate added in v0.22.0 

func (mr *MockWasmPluginHandlerMockRecorder) OnConfigUpdate(arg0 interface{}) *gomock.Call

OnConfigUpdate indicates an expected call of OnConfigUpdate.

func (*MockWasmPluginHandlerMockRecorder) OnPluginDestroy added in v0.22.0 

func (mr *MockWasmPluginHandlerMockRecorder) OnPluginDestroy(arg0 interface{}) *gomock.Call

OnPluginDestroy indicates an expected call of OnPluginDestroy.

func (*MockWasmPluginHandlerMockRecorder) OnPluginStart added in v0.22.0 

func (mr *MockWasmPluginHandlerMockRecorder) OnPluginStart(arg0 interface{}) *gomock.Call

OnPluginStart indicates an expected call of OnPluginStart.

type MockWasmPluginMockRecorder added in v0.22.0 

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

MockWasmPluginMockRecorder is the mock recorder for MockWasmPlugin.

func (*MockWasmPluginMockRecorder) Clear added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) Clear() *gomock.Call

Clear indicates an expected call of Clear.

func (*MockWasmPluginMockRecorder) EnsureInstanceNum added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) EnsureInstanceNum(arg0 interface{}) *gomock.Call

EnsureInstanceNum indicates an expected call of EnsureInstanceNum.

func (*MockWasmPluginMockRecorder) Exec added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) Exec(arg0 interface{}) *gomock.Call

Exec indicates an expected call of Exec.

func (*MockWasmPluginMockRecorder) GetInstance added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) GetInstance() *gomock.Call

GetInstance indicates an expected call of GetInstance.

func (*MockWasmPluginMockRecorder) GetPluginConfig added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) GetPluginConfig() *gomock.Call

GetPluginConfig indicates an expected call of GetPluginConfig.

func (*MockWasmPluginMockRecorder) GetVmConfig added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) GetVmConfig() *gomock.Call

GetVmConfig indicates an expected call of GetVmConfig.

func (*MockWasmPluginMockRecorder) InstanceNum added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) InstanceNum() *gomock.Call

InstanceNum indicates an expected call of InstanceNum.

func (*MockWasmPluginMockRecorder) PluginName added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) PluginName() *gomock.Call

PluginName indicates an expected call of PluginName.

func (*MockWasmPluginMockRecorder) ReleaseInstance added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) ReleaseInstance(arg0 interface{}) *gomock.Call

ReleaseInstance indicates an expected call of ReleaseInstance.

func (*MockWasmPluginMockRecorder) SetCpuLimit added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) SetCpuLimit(arg0 interface{}) *gomock.Call

SetCpuLimit indicates an expected call of SetCpuLimit.

func (*MockWasmPluginMockRecorder) SetMemLimit added in v0.22.0 

func (mr *MockWasmPluginMockRecorder) SetMemLimit(arg0 interface{}) *gomock.Call

SetMemLimit indicates an expected call of SetMemLimit.

type MockWasmPluginWrapper added in v0.22.0 

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

MockWasmPluginWrapper is a mock of WasmPluginWrapper interface.

func NewMockWasmPluginWrapper added in v0.22.0 

func NewMockWasmPluginWrapper(ctrl *gomock.Controller) *MockWasmPluginWrapper

NewMockWasmPluginWrapper creates a new mock instance.

func (*MockWasmPluginWrapper) EXPECT added in v0.22.0 

func (m *MockWasmPluginWrapper) EXPECT() *MockWasmPluginWrapperMockRecorder

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

func (*MockWasmPluginWrapper) GetConfig added in v0.22.0 

func (m *MockWasmPluginWrapper) GetConfig() v2.WasmPluginConfig

GetConfig mocks base method.

func (*MockWasmPluginWrapper) GetPlugin added in v0.22.0 

func (m *MockWasmPluginWrapper) GetPlugin() types.WasmPlugin

GetPlugin mocks base method.

func (*MockWasmPluginWrapper) RegisterPluginHandler added in v0.22.0 

func (m *MockWasmPluginWrapper) RegisterPluginHandler(arg0 types.WasmPluginHandler)

RegisterPluginHandler mocks base method.

func (*MockWasmPluginWrapper) Update added in v0.22.0 

func (m *MockWasmPluginWrapper) Update(arg0 v2.WasmPluginConfig, arg1 types.WasmPlugin)

Update mocks base method.

type MockWasmPluginWrapperMockRecorder added in v0.22.0 

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

MockWasmPluginWrapperMockRecorder is the mock recorder for MockWasmPluginWrapper.

func (*MockWasmPluginWrapperMockRecorder) GetConfig added in v0.22.0 

func (mr *MockWasmPluginWrapperMockRecorder) GetConfig() *gomock.Call

GetConfig indicates an expected call of GetConfig.

func (*MockWasmPluginWrapperMockRecorder) GetPlugin added in v0.22.0 

func (mr *MockWasmPluginWrapperMockRecorder) GetPlugin() *gomock.Call

GetPlugin indicates an expected call of GetPlugin.

func (*MockWasmPluginWrapperMockRecorder) RegisterPluginHandler added in v0.22.0 

func (mr *MockWasmPluginWrapperMockRecorder) RegisterPluginHandler(arg0 interface{}) *gomock.Call

RegisterPluginHandler indicates an expected call of RegisterPluginHandler.

func (*MockWasmPluginWrapperMockRecorder) Update added in v0.22.0 

func (mr *MockWasmPluginWrapperMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockWasmVM added in v0.22.0 

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

MockWasmVM is a mock of WasmVM interface.

func NewMockWasmVM added in v0.22.0 

func NewMockWasmVM(ctrl *gomock.Controller) *MockWasmVM

NewMockWasmVM creates a new mock instance.

func (*MockWasmVM) Close added in v1.3.0 

func (m *MockWasmVM) Close() error

Close mocks base method.

func (*MockWasmVM) EXPECT added in v0.22.0 

func (m *MockWasmVM) EXPECT() *MockWasmVMMockRecorder

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

func (*MockWasmVM) Init added in v0.22.0 

func (m *MockWasmVM) Init()

Init mocks base method.

func (*MockWasmVM) Name added in v0.22.0 

func (m *MockWasmVM) Name() string

Name mocks base method.

func (*MockWasmVM) NewModule added in v0.22.0 

func (m *MockWasmVM) NewModule(arg0 []byte) common.WasmModule

NewModule mocks base method.

type MockWasmVMMockRecorder added in v0.22.0 

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

MockWasmVMMockRecorder is the mock recorder for MockWasmVM.

func (*MockWasmVMMockRecorder) Close added in v1.3.0 

func (mr *MockWasmVMMockRecorder) Close() *gomock.Call

Close indicates an expected call of Close.

func (*MockWasmVMMockRecorder) Init added in v0.22.0 

func (mr *MockWasmVMMockRecorder) Init() *gomock.Call

Init indicates an expected call of Init.

func (*MockWasmVMMockRecorder) Name added in v0.22.0 

func (mr *MockWasmVMMockRecorder) Name() *gomock.Call

Name indicates an expected call of Name.

func (*MockWasmVMMockRecorder) NewModule added in v0.22.0 

func (mr *MockWasmVMMockRecorder) NewModule(arg0 interface{}) *gomock.Call

NewModule indicates an expected call of NewModule.

type MockWriteFilter 

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

MockWriteFilter is a mock of WriteFilter interface.

func NewMockWriteFilter 

func NewMockWriteFilter(ctrl *gomock.Controller) *MockWriteFilter

NewMockWriteFilter creates a new mock instance.

func (*MockWriteFilter) EXPECT 

func (m *MockWriteFilter) EXPECT() *MockWriteFilterMockRecorder

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

func (*MockWriteFilter) OnWrite 

func (m *MockWriteFilter) OnWrite(buffer []api.IoBuffer) api.FilterStatus

OnWrite mocks base method.

type MockWriteFilterMockRecorder 

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

MockWriteFilterMockRecorder is the mock recorder for MockWriteFilter.

func (*MockWriteFilterMockRecorder) OnWrite 

func (mr *MockWriteFilterMockRecorder) OnWrite(buffer interface{}) *gomock.Call

OnWrite indicates an expected call of OnWrite.

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.