consul

Documentation

Index

• Constants
• func NewPublisher(opts *publisher.Options) (publisher.Publisher, error)
• type Config
• type Publisher
  • func (p *Publisher) Connect(ctx context.Context) (err error)
  • func (p *Publisher) Disconnect(ctx context.Context) (err error)
  • func (p *Publisher) Publish(ctx context.Context, payload []byte) (err error)

Constants

const (
	ProviderName = "consul"
)

Functions

func NewPublisher

func NewPublisher(opts *publisher.Options) (publisher.Publisher, error)

NewPublisher creates a new publisher

Types

type Config

type Config struct {
	Topic         string         `json:"topic" yaml:"topic"`
	NodeFilter    string         `json:"node_filter" yaml:"node_filter"`
	ServiceFilter string         `json:"service_filter" yaml:"service_filter"`
	TagFilter     string         `json:"tag_filter" yaml:"tag_filter"`
	Version       int            `json:"version" yaml:"version"`
	Consul        *consul.Config `json:"consul" yaml:"consul"`
}

type Publisher

type Publisher struct {
	// contains filtered or unexported fields
}

func (*Publisher) Connect

func (p *Publisher) Connect(ctx context.Context) (err error)

func (*Publisher) Disconnect

func (p *Publisher) Disconnect(ctx context.Context) (err error)

func (*Publisher) Publish

func (p *Publisher) Publish(ctx context.Context, payload []byte) (err error)

Publish publishes a message to a topic