config

Documentation

Index

• Variables
• func NewPulsarClient(clientOptions pulsarClientOptions) (*pulsar.Client, error)
• func NewPulsarConsumer(client *pulsar.Client, consumerOptions pulsarConsumerOptions) (*[]pulsar.Consumer, error)
• type Config

Variables

var DefaultConfig = Config{
	Client: pulsarClientOptions{
		URL:               "pulsar://localhost:6650",
		ConnectionTimeout: 20 * time.Second,
	},
	Consumer: pulsarConsumerOptions{
		Topic:            "my-topic",
		SubscriptionName: "my-sub",
		NumWorkers:       1,
	},
}

Functions

func NewPulsarClient

func NewPulsarClient(clientOptions pulsarClientOptions) (*pulsar.Client, error)

func NewPulsarConsumer

func NewPulsarConsumer(client *pulsar.Client, consumerOptions pulsarConsumerOptions) (*[]pulsar.Consumer, error)

Types

type Config

type Config struct {
	Client   pulsarClientOptions   `config:"client"`
	Consumer pulsarConsumerOptions `config:"consumer"`
}