antipode

Documentation

Index

• Variables
• func Barrier(ctx context.Context, datastoreType Datastore_type, datastore_ID string) error
• func Consume(ctx context.Context, datastoreType Datastore_type, exchange string, key string, ...) (<-chan AntiObj, error)
• func InitCtx(ctx context.Context) context.Context
• func Requeue(ctx context.Context, datastoreType Datastore_type, key string, obj AntiObj) error
• 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 Document
• type MongoDB
  • func CreateMongoDB(host string, port string, database string) MongoDB
• type MySQL
  • func CreateMySQL(host string, port string, user string, password string, datastore string) MySQL
• 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, table string, key string) (string, []WriteIdentifier, error)

Variables

var (
	ErrNotFound = errors.New("not found")
)

Functions

func Barrier

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

func Consume

func Consume(ctx context.Context, datastoreType Datastore_type, exchange string, key string, stop chan struct{}) (<-chan AntiObj, error)

func InitCtx

func InitCtx(ctx context.Context) context.Context

func Requeue

func Requeue(ctx context.Context, datastoreType Datastore_type, key string, obj AntiObj) error

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, table 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 Document

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

type MongoDB

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

func CreateMongoDB

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

type MySQL

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

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

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

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
	TableId string
	Key     string
	Version string
}

func GetLineage

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

func Read

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