publisher

Documentation

Index

• Constants
• func InitSpanPublisherFromConfig() error
• type NatsMessage
• type NatsPublisher
  • func (n *NatsPublisher) Close() error
  • func (n *NatsPublisher) Publish(topic string, key, value []byte) error
  • func (n *NatsPublisher) PublishSpan(topic string, key []byte, spanData *orionproto.Span) error
• type Publisher
  • func GetPublisher() (Publisher, error)
• type SpanPublisher
  • func GetSpanPublisher() (SpanPublisher, error)

Constants

const (
	KAFKA   = "kafka"
	NATS    = "nats"
	CONSOLE = "console"
)

Functions

func InitSpanPublisherFromConfig

func InitSpanPublisherFromConfig() error

Types

type NatsMessage

type NatsMessage struct {
	Key   []byte
	Value []byte
}

type NatsPublisher

type NatsPublisher struct {
	URL       string
	ClusterID string
	ClientID  string
	// contains filtered or unexported fields
}

func (*NatsPublisher) Close

func (n *NatsPublisher) Close() error

func (*NatsPublisher) Publish

func (n *NatsPublisher) Publish(topic string, key, value []byte) error

func (*NatsPublisher) PublishSpan

func (n *NatsPublisher) PublishSpan(topic string, key []byte, spanData *orionproto.Span) error

type Publisher

type Publisher interface {
	Publish(topic string, key, value []byte) error
	Close() error
	// contains filtered or unexported methods
}

func GetPublisher

func GetPublisher() (Publisher, error)

type SpanPublisher

type SpanPublisher interface {
	Publisher
	PublishSpan(topic string, key []byte, spanData *orionproto.Span) error
}

func GetSpanPublisher

func GetSpanPublisher() (SpanPublisher, error)