Documentation ¶
Index ¶
- type MockedConnection
- func (c *MockedConnection) AddListener(event int, channel chan<- json.RawMessage)
- func (c *MockedConnection) AutoResubscribe() bool
- func (c *MockedConnection) CancelSubs()
- func (c *MockedConnection) Close() error
- func (c *MockedConnection) Connect() (bool, error)
- func (c *MockedConnection) EmitEvent(event int, arg interface{})
- func (c *MockedConnection) Host() string
- func (c *MockedConnection) IsReady() bool
- func (c *MockedConnection) ListenerCount(event int) int
- func (c *MockedConnection) Once(event int, channel chan<- json.RawMessage)
- func (c *MockedConnection) Port() int
- func (c *MockedConnection) ReconnectionDelay() time.Duration
- func (c *MockedConnection) RegisterSub(channel, roomID string, filters json.RawMessage, subscribeToSelf bool, ...)
- func (c *MockedConnection) RemoveAllListeners(event int)
- func (c *MockedConnection) RemoveListener(event int, channel chan<- json.RawMessage)
- func (c *MockedConnection) RenewSubscriptions()
- func (c *MockedConnection) RequestHistory() map[string]time.Time
- func (c *MockedConnection) Send(query []byte, options types.QueryOptions, ...) error
- func (c *MockedConnection) SetState(value int)
- func (c *MockedConnection) SslConnection() bool
- func (c *MockedConnection) State() int
- func (c *MockedConnection) UnregisterSub(roomID string)
- type MockedRoom
- func (m MockedRoom) Channel() string
- func (m MockedRoom) Filters() interface{}
- func (m MockedRoom) GetRealtimeChannel() chan<- *types.NotificationResult
- func (m MockedRoom) GetResponseChannel() chan<- *types.SubscribeResponse
- func (m MockedRoom) Id() string
- func (m MockedRoom) RoomId() string
- func (m MockedRoom) Subscribe(realtimeNotificationChannel chan<- *types.NotificationResult)
- func (m MockedRoom) SubscribeToSelf() bool
- func (m MockedRoom) Unsubscribe() error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type MockedConnection ¶
type MockedConnection struct { mock.Mock MockSend func([]byte, types.QueryOptions) *types.KuzzleResponse MockEmitEvent func(int, interface{}) MockAddListener func(int, chan<- json.RawMessage) MockRemoveAllListeners func(int) MockRemoveListener func(int, chan<- json.RawMessage) MockOnce func(int, chan<- json.RawMessage) MockListenerCount func(int) int // contains filtered or unexported fields }
func (*MockedConnection) AddListener ¶
func (c *MockedConnection) AddListener(event int, channel chan<- json.RawMessage)
func (*MockedConnection) AutoResubscribe ¶
func (c *MockedConnection) AutoResubscribe() bool
func (*MockedConnection) CancelSubs ¶
func (c *MockedConnection) CancelSubs()
func (*MockedConnection) Close ¶
func (c *MockedConnection) Close() error
func (*MockedConnection) Connect ¶
func (c *MockedConnection) Connect() (bool, error)
func (*MockedConnection) EmitEvent ¶
func (c *MockedConnection) EmitEvent(event int, arg interface{})
func (*MockedConnection) Host ¶
func (c *MockedConnection) Host() string
func (*MockedConnection) IsReady ¶
func (c *MockedConnection) IsReady() bool
func (*MockedConnection) ListenerCount ¶
func (c *MockedConnection) ListenerCount(event int) int
func (*MockedConnection) Once ¶
func (c *MockedConnection) Once(event int, channel chan<- json.RawMessage)
func (*MockedConnection) Port ¶
func (c *MockedConnection) Port() int
func (*MockedConnection) ReconnectionDelay ¶
func (c *MockedConnection) ReconnectionDelay() time.Duration
func (*MockedConnection) RegisterSub ¶
func (c *MockedConnection) RegisterSub(channel, roomID string, filters json.RawMessage, subscribeToSelf bool, notifChan chan<- types.NotificationResult, onReconnectChan chan<- interface{})
func (*MockedConnection) RemoveAllListeners ¶
func (c *MockedConnection) RemoveAllListeners(event int)
func (*MockedConnection) RemoveListener ¶
func (c *MockedConnection) RemoveListener(event int, channel chan<- json.RawMessage)
func (*MockedConnection) RenewSubscriptions ¶
func (c *MockedConnection) RenewSubscriptions()
func (*MockedConnection) RequestHistory ¶
func (c *MockedConnection) RequestHistory() map[string]time.Time
func (*MockedConnection) Send ¶
func (c *MockedConnection) Send(query []byte, options types.QueryOptions, responseChannel chan<- *types.KuzzleResponse, requestId string) error
func (*MockedConnection) SetState ¶
func (c *MockedConnection) SetState(value int)
mock specific functions
func (*MockedConnection) SslConnection ¶
func (c *MockedConnection) SslConnection() bool
func (*MockedConnection) State ¶
func (c *MockedConnection) State() int
func (*MockedConnection) UnregisterSub ¶
func (c *MockedConnection) UnregisterSub(roomID string)
type MockedRoom ¶
type MockedRoom struct {
MockedSubscribe func()
}
func (MockedRoom) Channel ¶
func (m MockedRoom) Channel() string
func (MockedRoom) Filters ¶
func (m MockedRoom) Filters() interface{}
func (MockedRoom) GetRealtimeChannel ¶
func (m MockedRoom) GetRealtimeChannel() chan<- *types.NotificationResult
func (MockedRoom) GetResponseChannel ¶
func (m MockedRoom) GetResponseChannel() chan<- *types.SubscribeResponse
func (MockedRoom) Id ¶
func (m MockedRoom) Id() string
func (MockedRoom) RoomId ¶
func (m MockedRoom) RoomId() string
func (MockedRoom) Subscribe ¶
func (m MockedRoom) Subscribe(realtimeNotificationChannel chan<- *types.NotificationResult)
func (MockedRoom) SubscribeToSelf ¶
func (m MockedRoom) SubscribeToSelf() bool
func (MockedRoom) Unsubscribe ¶
func (m MockedRoom) Unsubscribe() error
Click to show internal directories.
Click to hide internal directories.