infrastructure

package

v0.1.7 Latest Latest Go to latest Published: Jan 3, 2020 License: Apache-2.0 Imports: 12 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/HnH/choreographer

Links

Open Source Insights

Documentation ¶

Index ¶

func Boot(ctx context.Context) (<-chan struct{}, error)
func GetLogger() *zerolog.Logger
func GetPublisher() message.Publisher
func GetSubscriber() message.Subscriber
type BootParam
type PubSub
type PubSubConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func Boot ¶

func Boot(ctx context.Context) (<-chan struct{}, error)

Prepares infrastructure layer

func GetLogger ¶

func GetLogger() *zerolog.Logger

func GetPublisher ¶ added in v0.1.7

func GetPublisher() message.Publisher

func GetSubscriber ¶ added in v0.1.7

func GetSubscriber() message.Subscriber

Types ¶

type BootParam ¶ added in v0.1.7

type BootParam string

const BootPubSubConfig BootParam = "pubSubConfig"

type PubSub ¶

type PubSub struct {
	message.Publisher
	message.Subscriber
}

type PubSubConfig ¶ added in v0.1.1

type PubSubConfig struct {
	SaramaConfig  *sarama.Config
	Brokers       []string `config:"pub-sub-brokers,required"`
	ConsumerGroup string   `config:"pub-sub-consumer-group"`
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL