Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SinkConfig ¶
type SinkReader ¶ added in v1.1.0
type SinkReader interface {
Token() string
}
type SinkServer ¶
type SinkServer struct {
// contains filtered or unexported fields
}
SinkServer is responsible for pushing tokens to sinks
func NewSinkServer ¶
func NewSinkServer(conf *SinkServerConfig) *SinkServer
func (*SinkServer) Run ¶
func (ss *SinkServer) Run(ctx context.Context, incoming chan string, sinks []*SinkConfig) error
Run executes the server's run loop, which is responsible for reading in new tokens and pushing them out to the various sinks.
Click to show internal directories.
Click to hide internal directories.