azure_monitor

Documentation

Index

• Constants
• type AzureMonitorConfig
  • func (config *AzureMonitorConfig) Start(queue <-chan timestamped_message.TimestampedMessage)
• type LogEntry
  • func NewLogEntry(tsmsg timestamped_message.TimestampedMessage) LogEntry
  • func (msg *LogEntry) Serialize() []byte

Constants

const (
	MAX_RETRIES = 3
)

Types

type AzureMonitorConfig

type AzureMonitorConfig struct {
	Topic                  string `json:"topic"`
	DataCollectionEndpoint string `json:"data_collecton_endpoint"`
	ImmutableId            string `json:"immutable_id"`
	StreamName             string `json:"stream_name"`
}

func (*AzureMonitorConfig) Start

func (config *AzureMonitorConfig) Start(queue <-chan timestamped_message.TimestampedMessage)

type LogEntry

type LogEntry struct {
	TimeGenerated string
	Topic         string
	Message       string
}

func NewLogEntry

func NewLogEntry(tsmsg timestamped_message.TimestampedMessage) LogEntry

func (*LogEntry) Serialize

func (msg *LogEntry) Serialize() []byte