Documentation
¶
Overview ¶
Package aerospike implements the Aerospike database connector.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AerospikeKeyBins ¶
AerospikeKeyBins is an Aerospike Key and BinMap container use it to stream records to the AerospikeSink
type AerospikeProperties ¶
type AerospikeProperties struct {
Policy *aero.ClientPolicy
Hostname string
Port int
Namespase string
SetName string
}
AerospikeProperties is the Aerospike connector configuration properties
type AerospikeSink ¶
type AerospikeSink struct {
// contains filtered or unexported fields
}
AerospikeSink connector
func NewAerospikeSink ¶
func NewAerospikeSink(ctx context.Context, properties *AerospikeProperties, writePolicy *aero.WritePolicy) (*AerospikeSink, error)
NewAerospikeSink returns a new AerospikeSink instance
func (*AerospikeSink) In ¶
func (as *AerospikeSink) In() chan<- interface{}
In returns an input channel for receiving data
type AerospikeSource ¶
type AerospikeSource struct {
// contains filtered or unexported fields
}
AerospikeSource connector
func NewAerospikeSource ¶
func NewAerospikeSource(ctx context.Context, properties *AerospikeProperties, scanPolicy *aero.ScanPolicy, changeNotificationProperties *ChangeNotificationProperties) (*AerospikeSource, error)
NewAerospikeSource returns a new AerospikeSource instance set changeNotificationProperties to nil to scan the entire namespace/set
func (*AerospikeSource) Out ¶
func (as *AerospikeSource) Out() <-chan interface{}
Out returns an output channel for sending data
func (*AerospikeSource) Via ¶
func (as *AerospikeSource) Via(_flow streams.Flow) streams.Flow
Via streams data through the given flow
type ChangeNotificationProperties ¶
ChangeNotificationProperties holds the changes polling configuration
Source Files
Click to show internal directories.
Click to hide internal directories.