Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AerospikeCheckpointer ¶
type AerospikeCheckpointer struct {
// contains filtered or unexported fields
}
func NewAerospikeCheckpointer ¶
func NewAerospikeCheckpointer(client *aerospike.Client, namespace string) *AerospikeCheckpointer
func (*AerospikeCheckpointer) GetCheckpoint ¶
func (al *AerospikeCheckpointer) GetCheckpoint(key string) (string, error)
func (*AerospikeCheckpointer) SetCheckpoint ¶
func (al *AerospikeCheckpointer) SetCheckpoint(key, value string) error
type AerospikeReleaser ¶
type AerospikeReleaser struct {
// contains filtered or unexported fields
}
Click to show internal directories.
Click to hide internal directories.