apptail

Documentation

Index

• Constants
• func LoadConfig()
• type Config
  • func GetConfig() *Config
  • func (c *Config) GetLeakyBucket() *ratelimiter.LeakyBucket
• type Instance
  • func (instance *Instance) Identifier() string
  • func (instance *Instance) SendTimelineEvent(format string, v ...interface{})
  • func (instance *Instance) Tail(tracker storage.Tracker)

Constants

const (
	ID_LENGTH      = 12
	INITIAL_OFFSET = 0
	STDOUT         = "stdout"
	STDERR         = "stderr"
)

Functions

func LoadConfig

func LoadConfig()

Types

type Config

type Config struct {
	MaxRecordSize                  int    `json:"max_record_size"`
	MaxLinesPerSecond              int64  `json:"max_lines_per_second"`
	MaxLinesBurst                  uint16 `json:"max_lines_burst"`
	FileSizeLimit                  int64  `json:"read_limit"`
	PersistPositionIntervalSeconds int64  `json:"persist_position_interval_seconds"`
}

func GetConfig

func GetConfig() *Config

func (*Config) GetLeakyBucket

func (c *Config) GetLeakyBucket() *ratelimiter.LeakyBucket

type Instance

type Instance struct {
	AppGUID       string
	AppName       string
	AppSpace      string
	Type          string
	Index         int
	DockerId      string `json:"docker_id"`
	RootPath      string
	LogFiles      map[string]string
	DockerStreams bool `json:"docker_streams"`
	// contains filtered or unexported fields
}

Instance is the NATS message sent by dea_ng to notify of new instances.

func (*Instance) Identifier

func (instance *Instance) Identifier() string

func (*Instance) SendTimelineEvent

func (instance *Instance) SendTimelineEvent(format string, v ...interface{})

func (*Instance) Tail

func (instance *Instance) Tail(tracker storage.Tracker)

Tail begins tailing the files for this instance.