antipode

Documentation

Index

• func Barrier(ctx context.Context, datastoreType Datastore_type, datastore_ID string) error
• func InitCtx(ctx context.Context) context.Context
• func Transfer(ctx context.Context, lineage []WriteIdentifier) (context.Context, error)
• func Write(ctx context.Context, datastoreType Datastore_type, datastore_ID string, ...) (context.Context, error)
• type AntiObj
• type Datastore_type
• type RabbitMQ
  • func CreateRabbitMQ(rabbit_host string, rabbit_port string, rabbit_user string, ...) RabbitMQ
• type Redis
  • func CreateRedis(redis_host string, redis_port string, redis_password string) Redis
• type WriteIdentifier
  • func GetLineage(ctx context.Context) ([]WriteIdentifier, error)
  • func Read(ctx context.Context, datastoreType Datastore_type, key string) (string, []WriteIdentifier, error)

Functions

func Barrier

func Barrier(ctx context.Context, datastoreType Datastore_type, datastore_ID string) error

func InitCtx

func InitCtx(ctx context.Context) context.Context

func Transfer

func Transfer(ctx context.Context, lineage []WriteIdentifier) (context.Context, error)

func Write

func Write(ctx context.Context, datastoreType Datastore_type, datastore_ID string, key string, value string) (context.Context, error)

Types

type AntiObj

type AntiObj struct {
	Version string
	Lineage []WriteIdentifier
}

type Datastore_type

type Datastore_type interface {
	// contains filtered or unexported methods
}

type RabbitMQ

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

func CreateRabbitMQ

func CreateRabbitMQ(rabbit_host string, rabbit_port string, rabbit_user string, rabbit_password string, queue string) RabbitMQ

How can I close the connection?

type Redis

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

func CreateRedis

func CreateRedis(redis_host string, redis_port string, redis_password string) Redis

type WriteIdentifier

type WriteIdentifier struct {
	Dtstid  string
	Key     string
	Version string
}

func GetLineage

func GetLineage(ctx context.Context) ([]WriteIdentifier, error)

func Read

func Read(ctx context.Context, datastoreType Datastore_type, key string) (string, []WriteIdentifier, error)