internal

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

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