client

Jun 13, 2022

Changes in this version

type AMQPChannel

+ Ack func(tag uint64, multiple bool) error

+ Cancel func(consumer string, noWait bool) error

+ Confirm func(noWait bool) error

+ Consume func(queue, consumer string, autoAck, exclusive, noLocal, noWait bool, ...) (<-chan amqp.Delivery, error)

+ ExchangeBind func(destination, key, source string, noWait bool, args amqp.Table) error

+ ExchangeDeclare func(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

+ ExchangeDeclarePassive func(name, kind string, durable, autoDelete, internal, noWait bool, args amqp.Table) error

+ ExchangeDelete func(name string, ifUnused, noWait bool) error

+ ExchangeUnbind func(destination, key, source string, noWait bool, args amqp.Table) error

+ Flow func(active bool) error

+ Get func(queue string, autoAck bool) (msg amqp.Delivery, ok bool, err error)

+ GetNextPublishSeqNo func() uint64

+ Nack func(tag uint64, multiple bool, requeue bool) error

+ NotifyCancel func(c chan string) chan string

+ NotifyClose func(c chan *amqp.Error) chan *amqp.Error

+ NotifyConfirm func(ack, nack chan uint64) (chan uint64, chan uint64)

+ NotifyFlow func(c chan bool) chan bool

+ NotifyPublish func(confirm chan amqp.Confirmation) chan amqp.Confirmation

+ NotifyReturn func(c chan amqp.Return) chan amqp.Return

+ Publish func(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) error

+ PublishWithDeferredConfirm func(exchange, key string, mandatory, immediate bool, msg amqp.Publishing) (*amqp.DeferredConfirmation, error)

+ Qos func(prefetchCount, prefetchSize int, global bool) error

+ QueueBind func(name, key, exchange string, noWait bool, args amqp.Table) error

+ QueueDeclare func(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

+ QueueDeclarePassive func(name string, durable, autoDelete, exclusive, noWait bool, args amqp.Table) (amqp.Queue, error)

+ QueueDelete func(name string, ifUnused, ifEmpty, noWait bool) (int, error)

+ QueueInspect func(name string) (amqp.Queue, error)

+ QueuePurge func(name string, noWait bool) (int, error)

+ QueueUnbind func(name, key, exchange string, args amqp.Table) error

+ Recover func(requeue bool) error

+ Reject func(tag uint64, requeue bool) error

+ Tx func() error

+ TxCommit func() error

+ TxRollback func() error

type AMQPConnection

+ Close func() error

+ ConnectionState func() tls.ConnectionState

+ IsClosed func() bool

+ LocalAddr func() net.Addr

+ NotifyBlocked func(receiver chan amqp.Blocking) chan amqp.Blocking

+ NotifyClose func(receiver chan *amqp.Error) chan *amqp.Error

Jun 10, 2022

Changes in this version

type DownloadOptions

+ VersionID string

Jul 16, 2021

Changes in this version

type S3Manager

+ func (sm *S3Manager) Delete(bucketName string) error

+ func (sm *S3Manager) Get(bucketName string) *S3Wrapper

+ func (sm *S3Manager) GetAll() map[string]StorageAccessLayer

Nov 18, 2020

Changes in this version

+ type AMQPChannel struct

+ func NewAMQPChannel(channel *amqp.Channel) *AMQPChannel

+ func (ac *AMQPChannel) Close() error

+ func (ac *AMQPChannel) IsClosed() bool

+ type AMQPConnection struct

+ func NewAMQPConnection(config *AMQPConnectionConfig, logger *logrus.Logger) (*AMQPConnection, error)

+ func (ac *AMQPConnection) Channel() (*AMQPChannel, error)

+ type AMQPConnectionConfig struct

+ func NewAMQPConnectionConfig(host string, port int, user, password string, config *amqp.Config) *AMQPConnectionConfig

Aug 21, 2020

Changes in this version

+ type DownloadOptions struct

+ IfMatch string

+ IfModifiedSince *time.Time

+ IfNoneMatch string

+ IfUnmodifiedSince *time.Time

+ ResponseCacheControl string

+ ResponseContentDisposition string

+ ResponseContentEncoding string

+ ResponseContentLanguage string

+ ResponseContentType string

+ ResponseExpires *time.Time

+ VersionId string

+ type UploadOptions struct

+ ACL string

+ CacheControl string

+ ContentDisposition string

+ ContentEncoding string

+ ContentLanguage string

+ ContentMD5 string

+ ContentType string

+ Expires *time.Time

+ GrantFullControl string

+ GrantRead string

+ GrantReadACP string

+ GrantWriteACP string

+ Metadata map[string]string

+ ObjectLockMode string

+ ObjectLockRetainUntilDate *time.Time

+ ServerSideEncryption string

+ StorageClass string

+ Tagging string

Aug 18, 2020

Changes in this version

+ func NewAMQPConfig(vhost string, channelMax int, heartbeat time.Duration) amqp.Config

+ type AMQPManager struct

+ Reconnects uint64

+ func NewAMQPManager(config *AMQPManagerConfig, maxCap uint, logger *logrus.Logger) (*AMQPManager, error)

+ func (am *AMQPManager) AddClient() error

+ func (am *AMQPManager) Close() error

+ func (am *AMQPManager) GetClient() (*AMQPWrapper, error)

+ func (am *AMQPManager) PutClient(client *AMQPWrapper)

+ func (am *AMQPManager) SetPoolFactory(factory syncPkg.Factory)

+ type AMQPManagerConfig struct

+ func NewAMQPManagerConfig(address, user, password string, config *amqp.Config) *AMQPManagerConfig

+ type AMQPWrapper struct

+ Channel *amqp.Channel

+ Reconnects uint64

+ func NewAMQPWrapper(channel *amqp.Channel) *AMQPWrapper

type SFTPWrapper

+ Reconnects uint64

Jun 9, 2020

Changes in this version

+ type Factory func() interface

+ type Pool struct

+ func NewPool(maxCap uint, factory Factory, logger *logrus.Logger) *Pool

+ func (p *Pool) Get() (rv interface{})

+ func (p *Pool) Put(c interface{})

+ func (p *Pool) SetFactory(factory Factory)

type SFTPManager

+ func (sm *SFTPManager) SetPoolFactory(factory Factory)

Mar 9, 2020

Changes in this version

type SFTPManager

+ func (sm *SFTPManager) PutClient(client *SFTPWrapper)

Mar 9, 2020

Changes in this version

type SFTPManager

+ func (sm *SFTPManager) GetClient() (*SFTPWrapper, error)

Mar 9, 2020

Changes in this version

+ func NewAWSConfig() *aws.Config

+ func NewAWSSession(config *aws.Config) *session.Session

+ func NewS3Client(session *session.Session) *s3.S3

+ func NewSFTPClient(sshClient *ssh.Client) (*sftp.Client, error)

+ func NewSSHClient(host string, port uint32, sshConfig *ssh.ClientConfig) (*ssh.Client, error)

+ func NewSSHConfig(user string, password string) *ssh.ClientConfig

+ type AWSManager struct

+ S3Manager *S3Manager

+ func NewAWSManager(session *session.Session) *AWSManager

+ type RedisConfig struct

+ DB uint8

+ Host string

+ Port uint16

+ func (rc *RedisConfig) ToOption() *redis.Options

+ type RedisManager struct

+ Clients map[string][]*RedisWrapper

+ func NewRedisManager(config RedisConfig, logger *logrus.Logger) *RedisManager

+ func (rw *RedisManager) AddClient(category string, channel string, consumerName string) (*RedisWrapper, error)

+ func (rw *RedisManager) Close() error

+ func (rw *RedisManager) GetCategories() (clientsCat []string)

+ type RedisWrapper struct

+ Closed bool

+ func NewRedisWrapper(config RedisConfig, channel string, consumerName string) (*RedisWrapper, error)

+ func (w *RedisWrapper) AckMessage(group string, ids ...string) (int64, error)

+ func (w *RedisWrapper) AddMessage(data map[string]interface{}) (string, error)

+ func (w *RedisWrapper) Close() error

+ func (w *RedisWrapper) CreateGroup(group string, start string) (string, error)

+ func (w *RedisWrapper) DeleteGroup(group string) (int64, error)

+ func (w *RedisWrapper) DeleteGroupConsumer(group string) (int64, error)

+ func (w *RedisWrapper) DeleteMessage(ids ...string) (int64, error)

+ func (w *RedisWrapper) FlushAll() (string, error)

+ func (w *RedisWrapper) FlushAllAsync() (string, error)

+ func (w *RedisWrapper) FlushDB() (string, error)

+ func (w *RedisWrapper) FlushDBAsync() (string, error)

+ func (w *RedisWrapper) GetChannel() string

+ func (w *RedisWrapper) PendingMessage(group string) (*redis.XPending, error)

+ func (w *RedisWrapper) ReadGroupMessage(group string, count int64, block time.Duration, extraIds ...string) ([]redis.XStream, error)

+ func (w *RedisWrapper) ReadMessage(lastID string, count int64, block time.Duration) ([]redis.XStream, error)

+ func (w *RedisWrapper) ReadRangeMessage(start string, stop string) ([]redis.XMessage, error)

+ func (w *RedisWrapper) Reconnect() error

+ type S3Manager struct

+ S3 []StorageAccessLayer

+ func NewS3Manager(session *session.Session) *S3Manager

+ func (sm *S3Manager) Add(bucketName string) *S3Wrapper

+ type S3Wrapper struct

+ func NewS3Wrapper(bucketName string, s3Client *s3.S3) *S3Wrapper

+ func (s3w *S3Wrapper) Delete(path string, filename ...string) (*s3.DeleteObjectsOutput, error)

+ func (s3w *S3Wrapper) Download(path string, filename string, data io.WriterAt) (int64, error)

+ func (s3w *S3Wrapper) Read(path string, limit int64, readFrom string) (*s3.ListObjectsV2Output, error)

+ func (s3w *S3Wrapper) Upload(path string, filename string, data io.Reader) (string, error)

+ type SFTPManager struct

+ Conns []*SFTPWrapper

+ func NewSFTPManager(host string, port uint32, sshConfig *ssh.ClientConfig, logger *logrus.Logger) *SFTPManager

+ func (sm *SFTPManager) AddClient() (*SFTPWrapper, error)

+ func (sm *SFTPManager) Close() error

+ type SFTPWrapper struct

+ Client *sftp.Client

+ func NewSFTPWrapper(sshClient *ssh.Client, sftpClient *sftp.Client) *SFTPWrapper

+ func (s *SFTPWrapper) Close() error

+ type StorageAccessLayer interface

+ Delete func(path string, files ...string) (*s3.DeleteObjectsOutput, error)

+ Download func(path string, filename string, data io.WriterAt) (int64, error)

+ Read func(path string, limit int64, readFrom string) (*s3.ListObjectsV2Output, error)

+ Upload func(path string, filename string, data io.Reader) (string, error)