database

Documentation

Index

• func NewAMQP(opt *AmqpOptions) *amqp.Connection
• func NewKafkaAsyncProducer(opt *KafkaProducerOptions) sarama.AsyncProducer
• func NewKafkaConsumerGroup(opt *KafkaConsumerOptions) sarama.ConsumerGroup
• func NewKafkaSyncProducer(opt *KafkaProducerOptions) sarama.SyncProducer
• func NewPostgres(opt *PostgresOptions) *sqlx.DB
• func NewRedis(opt *RedisOptions) *redis.Client
• func NewRedisCluster(opt *RedisClusterOptions) *redis.ClusterClient
• type AmqpOptions
• type KafkaAdmin
  • func NewKafkaAdmin(opt *KafkaAdminOptions) *KafkaAdmin
  • func (admin *KafkaAdmin) CreateTopic(topic string, numPartitions int, replicationFactor int)
• type KafkaAdminOptions
• type KafkaConsumerOptions
• type KafkaProducerOptions
• type PostgresOptions
• type RedisClusterOptions
• type RedisOptions

Functions

func NewAMQP

func NewAMQP(opt *AmqpOptions) *amqp.Connection

func NewKafkaAsyncProducer

func NewKafkaAsyncProducer(opt *KafkaProducerOptions) sarama.AsyncProducer

func NewKafkaConsumerGroup

func NewKafkaConsumerGroup(opt *KafkaConsumerOptions) sarama.ConsumerGroup

func NewKafkaSyncProducer

func NewKafkaSyncProducer(opt *KafkaProducerOptions) sarama.SyncProducer

func NewPostgres

func NewPostgres(opt *PostgresOptions) *sqlx.DB

func NewRedis

func NewRedis(opt *RedisOptions) *redis.Client

func NewRedisCluster

func NewRedisCluster(opt *RedisClusterOptions) *redis.ClusterClient

Types

type AmqpOptions

type AmqpOptions struct {
	Username string
	Password string
	Host     string
	VHost    string
	Port     int
}

type KafkaAdmin

type KafkaAdmin struct {
	Client sarama.Client
}

func NewKafkaAdmin

func NewKafkaAdmin(opt *KafkaAdminOptions) *KafkaAdmin

func (*KafkaAdmin) CreateTopic

func (admin *KafkaAdmin) CreateTopic(topic string, numPartitions int, replicationFactor int)

type KafkaAdminOptions

type KafkaAdminOptions struct {
	Brokers []string
}

type KafkaConsumerOptions

type KafkaConsumerOptions struct {
	SaramaConfig  *sarama.Config
	Brokers       []string
	ConsumerGroup string
	InitialOffset int64
}

type KafkaProducerOptions

type KafkaProducerOptions struct {
	SaramaConfig   *sarama.Config
	Brokers        []string
	Topic          string
	RetryMax       int
	FlushFrequency int
	Acks           sarama.RequiredAcks
	ReturnSuccess  bool
}

type PostgresOptions

type PostgresOptions struct {
	Host            string
	DbName          string
	Username        string
	Password        string
	Sslmode         string
	Port            int
	MaxIdleConn     int
	MaxOpenConn     int
	MaxConnLifetime int
}

type RedisClusterOptions

type RedisClusterOptions struct {
	Addrs           []string
	Password        string
	DialTimeout     int
	ReadTimeout     int
	WriteTimeout    int
	MinIdleConn     int
	MaxIdleConn     int
	MaxActiveConn   int
	MaxConnLifetime int
}

type RedisOptions

type RedisOptions struct {
	Addr            string
	DialTimeout     int
	ReadTimeout     int
	WriteTimeout    int
	MinIdleConn     int
	MaxIdleConn     int
	MaxActiveConn   int
	MaxConnLifetime int
}