publisher

package

v0.0.0-...-9f72cad Latest Latest Go to latest Published: Dec 29, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Details

View Source

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

This section is empty.

func InitSpanPublisherFromConfig() error

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

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

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 interface {
	Publish(topic string, key, value []byte) error
	Close() error
	// contains filtered or unexported methods
}

func GetPublisher() (Publisher, error)

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

func GetSpanPublisher() (SpanPublisher, error)