Documentation
¶
Index ¶
- func GetSource() api.Source
- type KafkaSource
- func (s *KafkaSource) Close(_ api.StreamContext) error
- func (s *KafkaSource) Configure(topic string, props map[string]interface{}) error
- func (s *KafkaSource) GetOffset() (interface{}, error)
- func (s *KafkaSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)
- func (s *KafkaSource) Ping(d string, props map[string]interface{}) error
- func (s *KafkaSource) ResetOffset(input map[string]interface{}) error
- func (s *KafkaSource) Rewind(offset interface{}) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type KafkaSource ¶
type KafkaSource struct {
// contains filtered or unexported fields
}
func (*KafkaSource) Close ¶
func (s *KafkaSource) Close(_ api.StreamContext) error
func (*KafkaSource) Configure ¶
func (s *KafkaSource) Configure(topic string, props map[string]interface{}) error
func (*KafkaSource) GetOffset ¶
func (s *KafkaSource) GetOffset() (interface{}, error)
func (*KafkaSource) Open ¶
func (s *KafkaSource) Open(ctx api.StreamContext, consumer chan<- api.SourceTuple, errCh chan<- error)
func (*KafkaSource) ResetOffset ¶
func (s *KafkaSource) ResetOffset(input map[string]interface{}) error
func (*KafkaSource) Rewind ¶
func (s *KafkaSource) Rewind(offset interface{}) error
Source Files
Click to show internal directories.
Click to hide internal directories.