Documentation ¶
Index ¶
- Variables
- type Message
- type MockSignalStore
- func (s MockSignalStore) Broadcast(msg types.Message)
- func (s MockSignalStore) Conns() <-chan string
- func (s MockSignalStore) Deregister(name string)
- func (s MockSignalStore) Messages() <-chan Message
- func (s MockSignalStore) Register(server configure.SignalServer, tkn string)
- func (s MockSignalStore) Write(name string, msg types.Message) error
- type SignalStore
- func (s *SignalStore) Broadcast(msg types.Message)
- func (s *SignalStore) Conns() <-chan string
- func (s *SignalStore) Deregister(name string)
- func (s *SignalStore) Messages() <-chan Message
- func (s *SignalStore) Register(server configure.SignalServer, tkn string)
- func (s *SignalStore) Write(name string, msg types.Message) error
- type Store
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrSignalEntryNotReady = fmt.Errorf("signal entry not ready") ErrSignalEntryStopped = fmt.Errorf("signal entry stopped") )
View Source
var (
ErrSignalEntryNotLoaded = fmt.Errorf("signal entry not loaded")
)
Functions ¶
This section is empty.
Types ¶
type MockSignalStore ¶
type MockSignalStore struct { MessagesFunc func() <-chan Message ConnsFunc func() <-chan string RegisterFunc func(server configure.SignalServer, tkn string) BroadcastFunc func(msg types.Message) WriteFunc func(name string, msg types.Message) error DeregisterFunc func(name string) }
func (MockSignalStore) Broadcast ¶
func (s MockSignalStore) Broadcast(msg types.Message)
func (MockSignalStore) Conns ¶
func (s MockSignalStore) Conns() <-chan string
func (MockSignalStore) Deregister ¶
func (s MockSignalStore) Deregister(name string)
func (MockSignalStore) Messages ¶
func (s MockSignalStore) Messages() <-chan Message
func (MockSignalStore) Register ¶
func (s MockSignalStore) Register(server configure.SignalServer, tkn string)
type SignalStore ¶
type SignalStore struct {
// contains filtered or unexported fields
}
func (*SignalStore) Broadcast ¶
func (s *SignalStore) Broadcast(msg types.Message)
func (*SignalStore) Conns ¶
func (s *SignalStore) Conns() <-chan string
func (*SignalStore) Deregister ¶
func (s *SignalStore) Deregister(name string)
func (*SignalStore) Messages ¶
func (s *SignalStore) Messages() <-chan Message
func (*SignalStore) Register ¶
func (s *SignalStore) Register(server configure.SignalServer, tkn string)
Click to show internal directories.
Click to hide internal directories.