Documentation ¶
Index ¶
- Constants
- type ProducerClient
- type Sink
- func (s *Sink) Category() api.Category
- func (s *Sink) Config() interface{}
- func (s *Sink) Consume(batch api.Batch) api.Result
- func (s *Sink) Init(_ api.Context) error
- func (s *Sink) SetCodec(c codec.Codec)
- func (s *Sink) Start() error
- func (s *Sink) Stop()
- func (s *Sink) String() string
- func (s *Sink) Type() api.Type
Constants ¶
View Source
const Type = "pulsar"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ProducerClient ¶
type ProducerClient struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.