dataservice

package

v0.0.0-...-28547d7 Latest Latest Go to latest Published: Jun 2, 2021 License: Apache-2.0 Imports: 7 Imported by: 0

Details

View Source

const (
	SetUserInsight = "user_insight"
)

This section is empty.

func EnsureIndexes(client *aerospike.Client, descriptions []IndexDescription) error

This helper launches indexes creation tasks and processes their results

func ProcessIndexTask(provider func() (*aerospike.IndexTask, error), errorIfAlreadyExists bool) error

This helper waits until the index creation task is completed and processes the returned error if there is one

type DataServiceAerospike interface {
	IsConnected() bool
}

func NewDataServiceAerospike(client *aerospike.Client, namespace string) (DataServiceAerospike, error)

type IndexDescription struct {
	Namespace string
	Set       string
	Index     string
	Bin       string
	Type      aerospike.IndexType
}

type Kafka struct {
	// contains filtered or unexported fields
}

func NewKafka(config KafkaConfig) *Kafka