antipode

Apr 5, 2024

Changes in this version

type WriteIdentifier

+ TableId string

Apr 4, 2024

Changes in this version

+ type MySQL struct

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

Mar 26, 2024

Changes in this version

type Document

+ Key string

+ Value AntiObj

Mar 26, 2024

Changes in this version

+ type Document struct

Mar 25, 2024

Changes in this version

+ type MongoDB struct

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

+ type MongoDBObject struct

Feb 29, 2024

Changes in this version

+ 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 struct

+ Lineage []WriteIdentifier

+ Version string

+ type Datastore_type interface

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 struct

+ Dtstid string

+ Key string

+ Version string

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

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

Feb 27, 2024

Changes in this version

+ type RabbitMQ struct

+ type Redis struct