Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelStream ¶
type ChannelStream[T any] struct { // contains filtered or unexported fields }
func NewChannelStream ¶
func NewChannelStream[T any](bufferSize int) *ChannelStream[T]
func (*ChannelStream[T]) EstimatedSize ¶
func (c *ChannelStream[T]) EstimatedSize() int64
func (*ChannelStream[T]) ForeachRemaining ¶
func (c *ChannelStream[T]) ForeachRemaining(sink generic.Consumer) error
func (*ChannelStream[T]) Send ¶
func (c *ChannelStream[T]) Send(message T)
func (*ChannelStream[T]) TryAdvance ¶
func (c *ChannelStream[T]) TryAdvance(sink generic.Consumer) (bool, error)
type KafkaStream ¶
type KafkaStream struct {
// contains filtered or unexported fields
}
func NewKafkaStream ¶
func NewKafkaStream(ctx context.Context, cfg *KafkaStreamCfg) (*KafkaStream, error)
func (*KafkaStream) EstimatedSize ¶
func (k *KafkaStream) EstimatedSize() int64
func (*KafkaStream) ForeachRemaining ¶
func (k *KafkaStream) ForeachRemaining(sink generic.Consumer) error
func (*KafkaStream) TryAdvance ¶
func (k *KafkaStream) TryAdvance(sink generic.Consumer) (bool, error)
Click to show internal directories.
Click to hide internal directories.