pulsar

Documentation

Index

• func NewClient(config *Config, opts ...Option) (pulsarclient.Client, error)
• func NewLoggerWithZerolog(logger *zerolog.Logger) log.Logger
• type ClientManager
  • func NewClientManager(configs []Config, opts ...Option) (ClientManager, error)
• type Config
• type Option
  • func WithLogger(logger *zerolog.Logger) Option

Functions

func NewClient

func NewClient(config *Config, opts ...Option) (pulsarclient.Client, error)

func NewLoggerWithZerolog

func NewLoggerWithZerolog(logger *zerolog.Logger) log.Logger

NewLoggerWithZerolog creates a new logger which wraps the given zerolog.Logger

Types

type ClientManager

type ClientManager interface {
	GetClient(string) pulsarclient.Client
}

func NewClientManager

func NewClientManager(configs []Config, opts ...Option) (ClientManager, error)

type Config

type Config struct {
	Name  string `json:"name"`
	URL   string `json:"url"`
	Token string `json:"token"`
}

type Option

type Option func(*options)

func WithLogger

func WithLogger(logger *zerolog.Logger) Option