queue

Documentation

Index

• func InitializeQueue(ctx context.Context, config *Config) error
• func NewQueueClient() *client
• func Put(message interface{}) error
• func Put2Topic(topic string, msg interface{}) error
• func RegisterConsumeProcessor(processor func([]byte)) error
• type Config
  • func NewConfig() *Config

Functions

func InitializeQueue

func InitializeQueue(ctx context.Context, config *Config) error

func NewQueueClient

func NewQueueClient() *client

func Put

func Put(message interface{}) error

func Put2Topic

func Put2Topic(topic string, msg interface{}) error

func RegisterConsumeProcessor

func RegisterConsumeProcessor(processor func([]byte)) error

Types

type Config

type Config struct {
	Consumer *consumerConfig `yaml:"consumer"`
	Producer *producerConfig `yaml:"producer"`
}

func NewConfig

func NewConfig() *Config