logs

Documentation

Index

• func Poll(ctx context.Context, out chan<- LogEntry, client flyutil.Client, ...) error
• type LogEntry
• type LogOptions
• type LogStream
  • func NewNatsStream(ctx context.Context, apiClient flyutil.Client, opts *LogOptions) (LogStream, error)
  • func NewPollingStream(client flyutil.Client, opts *LogOptions) (LogStream, error)
• type Meta

Functions

func Poll

func Poll(ctx context.Context, out chan<- LogEntry, client flyutil.Client, opts *LogOptions) error

Types

type LogEntry

type LogEntry struct {
	Level     string `json:"level"`
	Instance  string `json:"instance"`
	Message   string `json:"message"`
	Region    string `json:"region"`
	Timestamp string `json:"timestamp"`
	Meta      Meta   `json:"meta"`
}

type LogOptions

type LogOptions struct {
	W io.Writer

	MaxBackoff time.Duration
	AppName    string
	VMID       string
	RegionCode string
	NoTail     bool
}

type LogStream

type LogStream interface {
	Err() error
	Stream(ctx context.Context, opts *LogOptions) <-chan LogEntry
}

func NewNatsStream

func NewNatsStream(ctx context.Context, apiClient flyutil.Client, opts *LogOptions) (LogStream, error)

func NewPollingStream

func NewPollingStream(client flyutil.Client, opts *LogOptions) (LogStream, error)

type Meta

type Meta struct {
	Instance string
	Region   string
	Event    struct {
		Provider string
	}
	HTTP struct {
		Request struct {
			ID      string
			Method  string
			Version string
		}
		Response struct {
			StatusCode int `json:"status_code"`
		}
	}
	Error struct {
		Code    int
		Message string
	}
	URL struct {
		Full string
	}
}