client

Documentation

Index

• Variables
• func ClearWorkCassandra(query string, params []any, key *string) error
• func ClearWorkCentauri(channel string, key *string) error
• func ClearWorkMongo(db, collection string, query string, key *string) error
• func ClearWorkMysql(query string, params []any, key *string) error
• func ClearWorkPsql(query string, params []any, key *string) error
• func CreateAWSSession(region, roleArn string) (*session.Session, *aws.Config, error)
• func CreateCassandraClient(hosts []string, user string, pass string, consistency string, keyspace string) error
• func CreateCentariClient(url string, privateKey []byte) error
• func CreateGCPPubSubClient(projectID string) error
• func CreateMongoClient(host string, port int, user string, pass string, db string) error
• func CreateMySqlClient(host string, port int, user string, pass string, db string) error
• func CreatePsqlClient(host string, port int, user, pass, db, sslMode string) error
• func CreateRabbitMQClient(url string) error
• func CreateRedisClient(host, port, password string) error
• func CreateSQSClient(region, roleArn string) (*sqs.SQS, error)
• func DeleteMessageSQS() error
• func GetWorkCassandra(query string, params []any, queryKey *bool) (*string, *string, error)
• func GetWorkCentauri(channel string) (*string, *string, error)
• func GetWorkMongo(db, collection, query string) (*string, *string, error)
• func GetWorkMysql(query string, params []any, queryKey *bool) (*string, *string, error)
• func GetWorkPsql(query string, params []any, queryKey *bool) (*string, *string, error)
• func HandleFailureCassandra(query string, params []any, key *string) error
• func HandleFailureCentauri(channel string, key *string) error
• func HandleFailureMongo(db, collection string, query string, key *string) error
• func HandleFailureMysql(query string, params []any, key *string) error
• func HandleFailurePsql(query string, params []any, key *string) error
• func ReceiveMessageGCPPubSub(subName string) (*pubsub.Message, error)
• func ReceiveMessageRabbitMQ() (*amqp.Delivery, error)
• func ReceiveMessageRedisList(queue string) (string, error)
• func ReceiveMessageRedisSubscription(channel string) (string, error)
• func ReceiveMessageSQS() (*sqs.Message, error)

Variables

var (
	RabbitMQClient *amqp.Connection
	RabbitMQQueue  string
)

var (
	SQSClient        *sqs.SQS
	SQSQueueURL      string
	SQSReceiptHandle string
)

var (
	CassandraClient *gocql.Session
)

var (
	GCPPubSubClient *pubsub.Client
)

var (
	MongoClient *mongo.Client
)

var (
	MysqlClient *sql.DB
)

var (
	PsqlClient *sql.DB
)

var (
	RedisClient *redis.Client
)

Functions

func ClearWorkCassandra

func ClearWorkCassandra(query string, params []any, key *string) error

func ClearWorkCentauri

func ClearWorkCentauri(channel string, key *string) error

func ClearWorkMongo

func ClearWorkMongo(db, collection string, query string, key *string) error

func ClearWorkMysql

func ClearWorkMysql(query string, params []any, key *string) error

func ClearWorkPsql

func ClearWorkPsql(query string, params []any, key *string) error

func CreateAWSSession

func CreateAWSSession(region, roleArn string) (*session.Session, *aws.Config, error)

CreateAWSSession will connect to AWS with the account's credentials from vault

func CreateCassandraClient

func CreateCassandraClient(hosts []string, user string, pass string, consistency string, keyspace string) error

func CreateCentariClient

func CreateCentariClient(url string, privateKey []byte) error

func CreateGCPPubSubClient

func CreateGCPPubSubClient(projectID string) error

func CreateMongoClient

func CreateMongoClient(host string, port int, user string, pass string, db string) error

func CreateMySqlClient

func CreateMySqlClient(host string, port int, user string, pass string, db string) error

func CreatePsqlClient

func CreatePsqlClient(host string, port int, user, pass, db, sslMode string) error

func CreateRabbitMQClient

func CreateRabbitMQClient(url string) error

func CreateRedisClient

func CreateRedisClient(host, port, password string) error

func CreateSQSClient

func CreateSQSClient(region, roleArn string) (*sqs.SQS, error)

func DeleteMessageSQS

func DeleteMessageSQS() error

DeleteMessage deletes a message from the queue

func GetWorkCassandra

func GetWorkCassandra(query string, params []any, queryKey *bool) (*string, *string, error)

func GetWorkCentauri

func GetWorkCentauri(channel string) (*string, *string, error)

func GetWorkMongo

func GetWorkMongo(db, collection, query string) (*string, *string, error)

func GetWorkMysql

func GetWorkMysql(query string, params []any, queryKey *bool) (*string, *string, error)

func GetWorkPsql

func GetWorkPsql(query string, params []any, queryKey *bool) (*string, *string, error)

func HandleFailureCassandra

func HandleFailureCassandra(query string, params []any, key *string) error

func HandleFailureCentauri

func HandleFailureCentauri(channel string, key *string) error

func HandleFailureMongo

func HandleFailureMongo(db, collection string, query string, key *string) error

func HandleFailureMysql

func HandleFailureMysql(query string, params []any, key *string) error

func HandleFailurePsql

func HandleFailurePsql(query string, params []any, key *string) error

func ReceiveMessageGCPPubSub

func ReceiveMessageGCPPubSub(subName string) (*pubsub.Message, error)

func ReceiveMessageRabbitMQ

func ReceiveMessageRabbitMQ() (*amqp.Delivery, error)

func ReceiveMessageRedisList

func ReceiveMessageRedisList(queue string) (string, error)

func ReceiveMessageRedisSubscription

func ReceiveMessageRedisSubscription(channel string) (string, error)

func ReceiveMessageSQS

func ReceiveMessageSQS() (*sqs.Message, error)

ReceiveMessage receives a single message from the queue