mocks

package
v0.0.0-...-964a6ab Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2026 License: MIT Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BlockProcessorMock 

type BlockProcessorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewBlockProcessorMock 

func NewBlockProcessorMock() *BlockProcessorMock

func (*BlockProcessorMock) Publish 

func (m *BlockProcessorMock) Publish(event blocks.BlockEvent)

func (*BlockProcessorMock) Running 

func (m *BlockProcessorMock) Running() bool

func (*BlockProcessorMock) Start 

func (m *BlockProcessorMock) Start()

func (*BlockProcessorMock) Stop 

func (m *BlockProcessorMock) Stop()

func (*BlockProcessorMock) Subscribe 

func (m *BlockProcessorMock) Subscribe(name string) *utils.Subscription[blocks.BlockEvent]

func (*BlockProcessorMock) UpdateBlock 

func (m *BlockProcessorMock) UpdateBlock(blockData protocol.Block, blockType protocol.BlockType)

type CacheConnectorMock 

type CacheConnectorMock struct {
	mock.Mock
}

func NewCacheConnectorMock 

func NewCacheConnectorMock() *CacheConnectorMock

func (*CacheConnectorMock) Id 

func (c *CacheConnectorMock) Id() string

func (*CacheConnectorMock) Initialize 

func (c *CacheConnectorMock) Initialize() error

func (*CacheConnectorMock) OutboxList 

func (c *CacheConnectorMock) OutboxList(ctx context.Context, cursor, limit int64) ([]map[string][]byte, error)

func (*CacheConnectorMock) OutboxRemove 

func (c *CacheConnectorMock) OutboxRemove(ctx context.Context, key string) error

func (*CacheConnectorMock) OutboxStore 

func (c *CacheConnectorMock) OutboxStore(ctx context.Context, key string, value []byte, ttl time.Duration) error

func (*CacheConnectorMock) Receive 

func (c *CacheConnectorMock) Receive(ctx context.Context, key string) ([]byte, error)

func (*CacheConnectorMock) Store 

func (c *CacheConnectorMock) Store(ctx context.Context, key string, object string, ttl time.Duration) error

type CacheProcessorMock 

type CacheProcessorMock struct {
	mock.Mock
}

func NewCacheProcessorMock 

func NewCacheProcessorMock() *CacheProcessorMock

func (*CacheProcessorMock) OutboxList 

func (c *CacheProcessorMock) OutboxList(_ context.Context, _, _ int64) ([]map[string][]byte, error)

func (*CacheProcessorMock) OutboxRemove 

func (c *CacheProcessorMock) OutboxRemove(_ context.Context, _ string) error

func (*CacheProcessorMock) OutboxStore 

func (c *CacheProcessorMock) OutboxStore(_ context.Context, _ string, _ []byte, _ time.Duration) error

func (*CacheProcessorMock) Receive 

func (c *CacheProcessorMock) Receive(ctx context.Context, chain chains.Chain, request protocol.RequestHolder) ([]byte, bool)

func (*CacheProcessorMock) Store 

func (c *CacheProcessorMock) Store(ctx context.Context, chain chains.Chain, request protocol.RequestHolder, response []byte)

type ClientLabelsDetectorMock 

type ClientLabelsDetectorMock struct {
	mock.Mock
}

func NewClientLabelsDetectorMock 

func NewClientLabelsDetectorMock() *ClientLabelsDetectorMock

func (*ClientLabelsDetectorMock) ClientVersionAndType 

func (m *ClientLabelsDetectorMock) ClientVersionAndType(data []byte) (string, string, error)

func (*ClientLabelsDetectorMock) NodeTypeRequest 

func (m *ClientLabelsDetectorMock) NodeTypeRequest() (protocol.RequestHolder, error)

type ConnectorMock 

type ConnectorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewConnectorMock 

func NewConnectorMock() *ConnectorMock

func NewConnectorMockWithType 

func NewConnectorMockWithType(connectorType specs.ApiConnectorType) *ConnectorMock

func (*ConnectorMock) GetType 

func (c *ConnectorMock) GetType() specs.ApiConnectorType

func (*ConnectorMock) GetUrl 

func (c *ConnectorMock) GetUrl() string

func (*ConnectorMock) Running 

func (c *ConnectorMock) Running() bool

func (*ConnectorMock) SendRequest 

func (c *ConnectorMock) SendRequest(ctx context.Context, request protocol.RequestHolder) protocol.ResponseHolder

func (*ConnectorMock) Start 

func (c *ConnectorMock) Start()

func (*ConnectorMock) Stop 

func (c *ConnectorMock) Stop()

func (*ConnectorMock) Subscribe 

func (c *ConnectorMock) Subscribe(ctx context.Context, request protocol.RequestHolder) (protocol.UpstreamSubscriptionResponse, error)

func (*ConnectorMock) SubscribeStates 

func (c *ConnectorMock) SubscribeStates(name string) *utils.Subscription[protocol.SubscribeConnectorState]

func (*ConnectorMock) Unsubscribe 

func (c *ConnectorMock) Unsubscribe(opId string)

type DelayedConnector 

type DelayedConnector struct {
	CacheConnectorMock
	// contains filtered or unexported fields
}

func NewDelayedConnector 

func NewDelayedConnector(sleep time.Duration) *DelayedConnector

func (*DelayedConnector) Id 

func (d *DelayedConnector) Id() string

func (*DelayedConnector) Receive 

func (d *DelayedConnector) Receive(ctx context.Context, key string) ([]byte, error)

func (*DelayedConnector) Store 

func (d *DelayedConnector) Store(ctx context.Context, key string, object string, ttl time.Duration) error

type DialWsServiceMock 

type DialWsServiceMock struct {
	mock.Mock
}

func NewDialWsServiceMock 

func NewDialWsServiceMock() *DialWsServiceMock

func (*DialWsServiceMock) NewConnectFunc 

func (m *DialWsServiceMock) NewConnectFunc(ctx context.Context) (ws.DialFunc, error)

type HeadProcessorMock 

type HeadProcessorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewHeadProcessorMock 

func NewHeadProcessorMock() *HeadProcessorMock

func (*HeadProcessorMock) GetCurrentBlock 

func (m *HeadProcessorMock) GetCurrentBlock() protocol.Block

func (*HeadProcessorMock) Publish 

func (m *HeadProcessorMock) Publish(event blocks.HeadEvent)

func (*HeadProcessorMock) Running 

func (m *HeadProcessorMock) Running() bool

func (*HeadProcessorMock) Start 

func (m *HeadProcessorMock) Start()

func (*HeadProcessorMock) Stop 

func (m *HeadProcessorMock) Stop()

func (*HeadProcessorMock) Subscribe 

func (m *HeadProcessorMock) Subscribe(name string) *utils.Subscription[blocks.HeadEvent]

func (*HeadProcessorMock) SubscribeWithReplay 

func (m *HeadProcessorMock) SubscribeWithReplay(name string) *utils.Subscription[blocks.HeadEvent]

func (*HeadProcessorMock) UpdateHead 

func (m *HeadProcessorMock) UpdateHead(height, slot uint64)

type HealthValidatorMock 

type HealthValidatorMock struct {
	mock.Mock
}

func NewHealthValidatorMock 

func NewHealthValidatorMock() *HealthValidatorMock

func (*HealthValidatorMock) Validate 

func (h *HealthValidatorMock) Validate() protocol.AvailabilityStatus

type LabelsDetectorMock 

type LabelsDetectorMock struct {
	mock.Mock
}

func NewLabelsDetectorMock 

func NewLabelsDetectorMock() *LabelsDetectorMock

func (*LabelsDetectorMock) DetectLabels 

func (m *LabelsDetectorMock) DetectLabels() map[string]string

type LabelsProcessorMock 

type LabelsProcessorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewLabelsProcessorMock 

func NewLabelsProcessorMock() *LabelsProcessorMock

func (*LabelsProcessorMock) Publish 

func (m *LabelsProcessorMock) Publish(data lo.Tuple2[string, string])

func (*LabelsProcessorMock) Running 

func (m *LabelsProcessorMock) Running() bool

func (*LabelsProcessorMock) Start 

func (m *LabelsProcessorMock) Start()

func (*LabelsProcessorMock) Stop 

func (m *LabelsProcessorMock) Stop()

func (*LabelsProcessorMock) Subscribe 

func (m *LabelsProcessorMock) Subscribe(name string) *utils.Subscription[lo.Tuple2[string, string]]

type LowerBoundDetectorMock 

type LowerBoundDetectorMock struct {
	mock.Mock
}

func NewLowerBoundDetectorMock 

func NewLowerBoundDetectorMock() *LowerBoundDetectorMock

func (*LowerBoundDetectorMock) DetectLowerBound 

func (m *LowerBoundDetectorMock) DetectLowerBound(ctx context.Context) ([]protocol.LowerBoundData, error)

func (*LowerBoundDetectorMock) Period 

func (m *LowerBoundDetectorMock) Period() time.Duration

func (*LowerBoundDetectorMock) SupportedTypes 

func (m *LowerBoundDetectorMock) SupportedTypes() []protocol.LowerBoundType

type LowerBoundProcessorMock 

type LowerBoundProcessorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewLowerBoundProcessorMock 

func NewLowerBoundProcessorMock() *LowerBoundProcessorMock

func (*LowerBoundProcessorMock) PredictLowerBound 

func (m *LowerBoundProcessorMock) PredictLowerBound(boundType protocol.LowerBoundType, timeOffset int64) int64

func (*LowerBoundProcessorMock) Publish 

func (m *LowerBoundProcessorMock) Publish(data protocol.LowerBoundData)

func (*LowerBoundProcessorMock) Running 

func (m *LowerBoundProcessorMock) Running() bool

func (*LowerBoundProcessorMock) Start 

func (m *LowerBoundProcessorMock) Start()

func (*LowerBoundProcessorMock) Stop 

func (m *LowerBoundProcessorMock) Stop()

func (*LowerBoundProcessorMock) Subscribe 

func (m *LowerBoundProcessorMock) Subscribe(name string) *utils.Subscription[protocol.LowerBoundData]

type MethodsDetectorMock 

type MethodsDetectorMock struct {
	mock.Mock
}

func NewMethodsDetectorMock 

func NewMethodsDetectorMock() *MethodsDetectorMock

func (*MethodsDetectorMock) DetectUnsupported 

func (m *MethodsDetectorMock) DetectUnsupported(ctx context.Context) mapset.Set[string]

type MethodsMock 

type MethodsMock struct {
	mock.Mock
}

func NewMethodsMock 

func NewMethodsMock() *MethodsMock

func (*MethodsMock) GetMethod 

func (m *MethodsMock) GetMethod(methodName string) *specs.Method

func (*MethodsMock) GetSupportedMethods 

func (m *MethodsMock) GetSupportedMethods() mapset.Set[string]

func (*MethodsMock) HasMethod 

func (m *MethodsMock) HasMethod(s string) bool

func (*MethodsMock) IsCacheable 

func (m *MethodsMock) IsCacheable(ctx context.Context, data any, methodName string) bool

type MethodsProcessorMock 

type MethodsProcessorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewMethodsProcessorMock 

func NewMethodsProcessorMock() *MethodsProcessorMock

func (*MethodsProcessorMock) Publish 

func (m *MethodsProcessorMock) Publish(unsupported mapset.Set[string])

func (*MethodsProcessorMock) Running 

func (m *MethodsProcessorMock) Running() bool

func (*MethodsProcessorMock) Start 

func (m *MethodsProcessorMock) Start()

func (*MethodsProcessorMock) Stop 

func (m *MethodsProcessorMock) Stop()

func (*MethodsProcessorMock) Subscribe 

func (m *MethodsProcessorMock) Subscribe(name string) *utils.Subscription[mapset.Set[string]]

type MockAuthProcessor 

type MockAuthProcessor struct {
	mock.Mock
}

func NewMockAuthProcessor 

func NewMockAuthProcessor() *MockAuthProcessor

func (*MockAuthProcessor) Authenticate 

func (m *MockAuthProcessor) Authenticate(ctx context.Context, payload auth.AuthPayload) error

func (*MockAuthProcessor) GetKeyValue 

func (m *MockAuthProcessor) GetKeyValue(payload auth.AuthPayload) string

func (*MockAuthProcessor) PostKeyValidate 

func (m *MockAuthProcessor) PostKeyValidate(ctx context.Context, payload auth.AuthPayload, request protocol.RequestHolder) error

func (*MockAuthProcessor) PreKeyValidate 

func (m *MockAuthProcessor) PreKeyValidate(ctx context.Context, payload auth.AuthPayload) ([]string, error)

type MockDrpcHttpcConnector 

type MockDrpcHttpcConnector struct {
	mock.Mock
}

func NewMockDrpcHttpcConnector 

func NewMockDrpcHttpcConnector() *MockDrpcHttpcConnector

func (*MockDrpcHttpcConnector) LoadOwnerKeys 

func (m *MockDrpcHttpcConnector) LoadOwnerKeys(ownerId, apiToken string) ([]*drpc.DrpcKey, error)

func (*MockDrpcHttpcConnector) OwnerExists 

func (m *MockDrpcHttpcConnector) OwnerExists(ownerId, apiToken string) error

func (*MockDrpcHttpcConnector) UploadStats 

func (m *MockDrpcHttpcConnector) UploadStats(stats []byte, ownerId, apiToken string) error

type MockForkChoice 

type MockForkChoice struct {
	mock.Mock
}

func NewMockForkChoice 

func NewMockForkChoice() *MockForkChoice

func (*MockForkChoice) Choose 

func (m *MockForkChoice) Choose(upstreamId string, event *protocol.HeadUpstreamEvent) (bool, protocol.Block)

type MockIntegrationClient 

type MockIntegrationClient struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewMockIntegrationClient 

func NewMockIntegrationClient(integrationType integration.IntegrationType) *MockIntegrationClient

func (*MockIntegrationClient) GetStatsSchema 

func (m *MockIntegrationClient) GetStatsSchema() []statsdata.StatsDims

func (*MockIntegrationClient) InitKeys 

func (m *MockIntegrationClient) InitKeys(id string, cfg config.IntegrationKeyConfig) (chan keydata.KeyEvent, error)

func (*MockIntegrationClient) ProcessStatsData 

func (m *MockIntegrationClient) ProcessStatsData(aggregatedData *utils.CMap[statsdata.StatsKey, statsdata.StatsData]) error

func (*MockIntegrationClient) Type 

func (m *MockIntegrationClient) Type() integration.IntegrationType

type MockStrategy 

type MockStrategy struct {
	mock.Mock
}

func NewMockStrategy 

func NewMockStrategy() *MockStrategy

func (*MockStrategy) SelectUpstream 

func (m *MockStrategy) SelectUpstream(request protocol.RequestHolder) (string, error)

type RequestOperationMock 

type RequestOperationMock struct {
	MethodValue          string
	SubIDValue           string
	SubIDBytesValue      []byte
	SubTypeValue         string
	CompletedValue       bool
	ShouldDoOnCloseValue bool
	ResponseChannel      chan protocol.SubResponse
	InternalChannel      chan protocol.SubResponse
	DoneChannel          <-chan struct{}
	IDValue              string
	DoOnCloseFunc        ws.DoOnClose
	// contains filtered or unexported fields
}

func NewRequestOperationMock 

func NewRequestOperationMock() *RequestOperationMock

func (*RequestOperationMock) Cancel 

func (r *RequestOperationMock) Cancel()

func (*RequestOperationMock) Complete 

func (r *RequestOperationMock) Complete()

func (*RequestOperationMock) CtxDone 

func (r *RequestOperationMock) CtxDone() <-chan struct{}

func (*RequestOperationMock) DoOnClose 

func (r *RequestOperationMock) DoOnClose()

func (*RequestOperationMock) GetChannel 

func (r *RequestOperationMock) GetChannel(messageType ws.MessageType) chan protocol.SubResponse

func (*RequestOperationMock) Id 

func (r *RequestOperationMock) Id() string

func (*RequestOperationMock) IsCompleted 

func (r *RequestOperationMock) IsCompleted() bool

func (*RequestOperationMock) Method 

func (r *RequestOperationMock) Method() string

func (*RequestOperationMock) SetSkipDoOnClose 

func (r *RequestOperationMock) SetSkipDoOnClose()

func (*RequestOperationMock) SetSubID 

func (r *RequestOperationMock) SetSubID(subID []byte)

func (*RequestOperationMock) ShouldDoOnClose 

func (r *RequestOperationMock) ShouldDoOnClose() bool

func (*RequestOperationMock) SubID 

func (r *RequestOperationMock) SubID() string

func (*RequestOperationMock) SubIdBytes 

func (r *RequestOperationMock) SubIdBytes() []byte

func (*RequestOperationMock) SubType 

func (r *RequestOperationMock) SubType() string

func (*RequestOperationMock) Write 

func (r *RequestOperationMock) Write(message protocol.SubResponse, messageType ws.MessageType)

type RequestRegistryMock 

type RequestRegistryMock struct {
	mock.Mock
}

func NewRequestRegistryMock 

func NewRequestRegistryMock() *RequestRegistryMock

func (*RequestRegistryMock) Abort 

func (m *RequestRegistryMock) Abort(requestId string)

func (*RequestRegistryMock) Cancel 

func (m *RequestRegistryMock) Cancel(opId string)

func (*RequestRegistryMock) CancelAll 

func (m *RequestRegistryMock) CancelAll()

func (*RequestRegistryMock) OnRpcMessage 

func (m *RequestRegistryMock) OnRpcMessage(response *protocol.WsResponse)

func (*RequestRegistryMock) OnSubscriptionMessage 

func (m *RequestRegistryMock) OnSubscriptionMessage(response *protocol.WsResponse)

func (*RequestRegistryMock) Register 

func (m *RequestRegistryMock) Register(
	ctx context.Context,
	request protocol.RequestHolder,
	requestId, subType string,
	doOnClose ws.DoOnClose,
) ws.RequestOperation

func (*RequestRegistryMock) Start 

func (m *RequestRegistryMock) Start(req ws.RequestOperation)

type SettingsValidatorMock 

type SettingsValidatorMock struct {
	mock.Mock
}

func NewSettingsValidatorMock 

func NewSettingsValidatorMock() *SettingsValidatorMock

func (*SettingsValidatorMock) Validate 

func (s *SettingsValidatorMock) Validate() validations.ValidationSettingResult

type UpstreamStateEventProcessorMock 

type UpstreamStateEventProcessorMock struct {
	mock.Mock
	// contains filtered or unexported fields
}

func NewUpstreamStateEventProcessorMock 

func NewUpstreamStateEventProcessorMock(processorType event_processors.EventProcessorType) *UpstreamStateEventProcessorMock

func (*UpstreamStateEventProcessorMock) Running 

func (m *UpstreamStateEventProcessorMock) Running() bool

func (*UpstreamStateEventProcessorMock) SetEmitter 

func (m *UpstreamStateEventProcessorMock) SetEmitter(emitter event_processors.Emitter)

func (*UpstreamStateEventProcessorMock) Start 

func (m *UpstreamStateEventProcessorMock) Start()

func (*UpstreamStateEventProcessorMock) Stop 

func (m *UpstreamStateEventProcessorMock) Stop()

func (*UpstreamStateEventProcessorMock) Type 

func (m *UpstreamStateEventProcessorMock) Type() event_processors.EventProcessorType

type UpstreamSupervisorMock 

type UpstreamSupervisorMock struct {
	mock.Mock
}

func NewUpstreamSupervisorMock 

func NewUpstreamSupervisorMock() *UpstreamSupervisorMock

func (*UpstreamSupervisorMock) GetChainSupervisor 

func (u *UpstreamSupervisorMock) GetChainSupervisor(chain chains.Chain) upstreams.ChainSupervisor

func (*UpstreamSupervisorMock) GetChainSupervisors 

func (u *UpstreamSupervisorMock) GetChainSupervisors() []upstreams.ChainSupervisor

func (*UpstreamSupervisorMock) GetExecutor 

func (u *UpstreamSupervisorMock) GetExecutor() failsafe.Executor[*protocol.ResponseHolderWrapper]

func (*UpstreamSupervisorMock) GetUpstream 

func (u *UpstreamSupervisorMock) GetUpstream(id string) upstreams.Upstream

func (*UpstreamSupervisorMock) StartUpstreams 

func (u *UpstreamSupervisorMock) StartUpstreams()

func (*UpstreamSupervisorMock) SubscribeChainSupervisor 

func (u *UpstreamSupervisorMock) SubscribeChainSupervisor(name string) *utils.Subscription[upstreams.ChainSupervisorEvent]

type WsConnectorMock 

type WsConnectorMock struct {
	mock.Mock
}

func NewWsConnectorMock 

func NewWsConnectorMock() *WsConnectorMock

func (*WsConnectorMock) GetType 

func (c *WsConnectorMock) GetType() specs.ApiConnectorType

func (*WsConnectorMock) GetUrl 

func (c *WsConnectorMock) GetUrl() string

func (*WsConnectorMock) Running 

func (c *WsConnectorMock) Running() bool

func (*WsConnectorMock) SendRequest 

func (c *WsConnectorMock) SendRequest(ctx context.Context, request protocol.RequestHolder) protocol.ResponseHolder

func (*WsConnectorMock) Start 

func (c *WsConnectorMock) Start()

func (*WsConnectorMock) Stop 

func (c *WsConnectorMock) Stop()

func (*WsConnectorMock) Subscribe 

func (c *WsConnectorMock) Subscribe(ctx context.Context, request protocol.RequestHolder) (protocol.UpstreamSubscriptionResponse, error)

func (*WsConnectorMock) SubscribeStates 

func (c *WsConnectorMock) SubscribeStates(name string) *utils.Subscription[protocol.SubscribeConnectorState]

func (*WsConnectorMock) Unsubscribe 

func (c *WsConnectorMock) Unsubscribe(opId string)

type WsProcessorMock 

type WsProcessorMock struct {
	mock.Mock
}

func NewWsProcessorMock 

func NewWsProcessorMock() *WsProcessorMock

func (*WsProcessorMock) GetUrl 

func (w *WsProcessorMock) GetUrl() string

func (*WsProcessorMock) Running 

func (w *WsProcessorMock) Running() bool

func (*WsProcessorMock) SendRpcRequest 

func (w *WsProcessorMock) SendRpcRequest(ctx context.Context, upstreamRequest protocol.RequestHolder) (protocol.SubResponse, error)

func (*WsProcessorMock) SendWsRequest 

func (w *WsProcessorMock) SendWsRequest(ctx context.Context, upstreamRequest protocol.RequestHolder) (chan protocol.SubResponse, string, error)

func (*WsProcessorMock) Start 

func (w *WsProcessorMock) Start()

func (*WsProcessorMock) Stop 

func (w *WsProcessorMock) Stop()

func (*WsProcessorMock) SubscribeWsStates 

func (w *WsProcessorMock) SubscribeWsStates(name string) *utils.Subscription[protocol.SubscribeConnectorState]

func (*WsProcessorMock) Unsubscribe 

func (w *WsProcessorMock) Unsubscribe(opId string)

type WsProtocolMock 

type WsProtocolMock struct {
	mock.Mock
}

func NewWsProtocolMock 

func NewWsProtocolMock() *WsProtocolMock

func (*WsProtocolMock) DoOnCloseFunc 

func (m *WsProtocolMock) DoOnCloseFunc(writeRequestFunc ws.WriteRequest) ws.DoOnClose

func (*WsProtocolMock) ParseWsMessage 

func (m *WsProtocolMock) ParseWsMessage(payload []byte) (*protocol.WsResponse, error)

func (*WsProtocolMock) RequestFrame 

func (m *WsProtocolMock) RequestFrame(request protocol.RequestHolder) (*ws.RequestFrame, error)

type WsSessionMock 

type WsSessionMock struct {
	mock.Mock
}

func NewWsSessionMock 

func NewWsSessionMock() *WsSessionMock

func (*WsSessionMock) CloseCurrent 

func (m *WsSessionMock) CloseCurrent() error

func (*WsSessionMock) Generation 

func (m *WsSessionMock) Generation() uint64

func (*WsSessionMock) IsClosed 

func (m *WsSessionMock) IsClosed() bool

func (*WsSessionMock) LoadConnection 

func (m *WsSessionMock) LoadConnection() *websocket.Conn

func (*WsSessionMock) SetConnection 

func (m *WsSessionMock) SetConnection(conn *websocket.Conn)

func (*WsSessionMock) WriteMessage 

func (m *WsSessionMock) WriteMessage(endpoint string, message []byte) error

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.