logemitter

Documentation

Index

• Variables
• type Emitter
• type LoggregatorEmitter
  • func NewEmitter(loggregatorServer, sourceName, sourceId string, debug bool) (*LoggregatorEmitter, error)
  • func (e *LoggregatorEmitter) Emit(appid, message string)
  • func (e *LoggregatorEmitter) EmitError(appid, message string)
  • func (e *LoggregatorEmitter) EmitLogMessage(logMessage *events.LogMessage)

Variables

var (
	MAX_MESSAGE_BYTE_SIZE = (9 * 1024) - 512
	TRUNCATED_BYTES       = []byte("TRUNCATED")
	TRUNCATED_OFFSET      = MAX_MESSAGE_BYTE_SIZE - len(TRUNCATED_BYTES)
)

var ERR_SHARED_SECRET_NOT_SET = errors.New("Environment variable LOGGREGATOR_SHARED_SECRET is not set. Emitter requires a shared secret to sign log messages")

Types

type Emitter

type Emitter interface {
	Emit(string, string)
	EmitError(string, string)
	EmitLogMessage(*events.LogMessage)
}

type LoggregatorEmitter

type LoggregatorEmitter struct {
	LoggregatorClient loggregatorclient.LoggregatorClient
	// contains filtered or unexported fields
}

func NewEmitter

func NewEmitter(loggregatorServer, sourceName, sourceId string, debug bool) (*LoggregatorEmitter, error)

func (*LoggregatorEmitter) Emit

func (e *LoggregatorEmitter) Emit(appid, message string)

func (*LoggregatorEmitter) EmitError

func (e *LoggregatorEmitter) EmitError(appid, message string)

func (*LoggregatorEmitter) EmitLogMessage

func (e *LoggregatorEmitter) EmitLogMessage(logMessage *events.LogMessage)