drain

Documentation

Index

• Constants
• func RemoveOrphanedDrains()
• type AppLogDrain
  • func NewAppLogDrain(appGUID string) (*AppLogDrain, error)
  • func (d *AppLogDrain) Id() string
  • func (d *AppLogDrain) Start() (chan string, error)
  • func (d *AppLogDrain) Stop(reason error)
  • func (d *AppLogDrain) Wait() error

Constants

const DRAIN_PREFIX = "tmp.applog_endpoint"

const LINESERVER_PROTO = "udp"

UDP can lead to data loss, but that's OK for log streaming.

Functions

func RemoveOrphanedDrains

func RemoveOrphanedDrains()

RemoveOrphanedDrains removes all drains created by applog_endpoint.

Types

type AppLogDrain

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

func NewAppLogDrain

func NewAppLogDrain(appGUID string) (*AppLogDrain, error)

func (*AppLogDrain) Id

func (d *AppLogDrain) Id() string

func (*AppLogDrain) Start

func (d *AppLogDrain) Start() (chan string, error)

func (*AppLogDrain) Stop

func (d *AppLogDrain) Stop(reason error)

func (*AppLogDrain) Wait

func (d *AppLogDrain) Wait() error