client

package

v0.0.15 Latest Latest Go to latest Published: Jul 31, 2022 License: MIT Imports: 26 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/robertlestak/procx

Links

Open Source Insights

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)

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	RabbitMQClient *amqp.Connection
	RabbitMQQueue  string
)

View Source

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

View Source

var (
	CassandraClient *gocql.Session
)

View Source

var (
	GCPPubSubClient *pubsub.Client
)

View Source

var (
	MongoClient *mongo.Client
)

View Source

var (
	MysqlClient *sql.DB
)

View Source

var (
	PsqlClient *sql.DB
)

View Source

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

Types ¶

This section is empty.

Source Files ¶

View all Source files

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