Documentation ¶
Index ¶
- Constants
- type Sink
- func (s *Sink) Dequeue(ctx context.Context, envelopes []envelope.Envelope) error
- func (s *Sink) Enqueue(envelopes []envelope.Envelope) error
- func (s *Sink) Initialize(conf config.Sink) error
- func (s *Sink) Metadata() backendutils.SinkMetadata
- func (s *Sink) Shutdown() error
- func (s *Sink) StartWorker() error
Constants ¶
View Source
const ( PUBNUB_PUBLISH_URL string = "ps.pndsn.com/publish" PUBNUB_HTTP_PROTOCOL string = "https" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Sink ¶
type Sink struct {
// contains filtered or unexported fields
}
func (*Sink) Metadata ¶
func (s *Sink) Metadata() backendutils.SinkMetadata
func (*Sink) StartWorker ¶
Click to show internal directories.
Click to hide internal directories.