antipode

package
v0.4.43 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 10, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Barrier added in v0.3.1

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

func InitCtx added in v0.3.1

func InitCtx(ctx context.Context) context.Context

func Transfer added in v0.3.1

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

func Write added in v0.3.1

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

Types

type AntiObj added in v0.3.1

type AntiObj struct {
	Version string
	Lineage []WriteIdentifier
}

type Datastore_type added in v0.3.1

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

type RabbitMQ

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

func CreateRabbitMQ added in v0.3.1

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 added in v0.3.1

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

type WriteIdentifier added in v0.3.1

type WriteIdentifier struct {
	Dtstid  string
	Key     string
	Version string
}

func GetLineage added in v0.3.1

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

func Read added in v0.3.1

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL