signal_store

type Message struct {
	Msg  types.Message
	Node string
}

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)
}

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

type Store interface {
	Messages() <-chan Message
	Conns() <-chan string
	Register(server configure.SignalServer, tkn string)
	Broadcast(msg types.Message)
	Write(name string, msg types.Message) error
	Deregister(name string)
}