antipode

package
v0.5.35 Latest Latest
Warning

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

Go to latest
Published: Apr 30, 2024 License: Apache-2.0 Imports: 12 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, table 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 Document added in v0.5.6

type Document struct {
	Key   string  `bson:"key"`
	Value AntiObj `bson:"value"`
}

type MongoDB added in v0.5.4

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

func CreateMongoDB added in v0.5.4

func CreateMongoDB(host string, port string, database string) MongoDB

type MySQL added in v0.5.13

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

It assumes by default that the table where the queries will be executed has exactly two columns called k and value

func CreateMySQL added in v0.5.13

func CreateMySQL(host string, port string, user string, password string, datastore string) MySQL

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? É má prática manter a conexão sempre aberta?

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
	TableId 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, table string, key string) (string, []WriteIdentifier, error)

Jump to

Keyboard shortcuts

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