logs

Documentation

Index

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

Functions

func Poll

func Poll(ctx context.Context, out chan<- LogEntry, client WebClient, 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 WebClient, opts *LogOptions) (LogStream, error)

func NewPollingStream

func NewPollingStream(client WebClient) LogStream

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
	}
}

type WebClient

type WebClient interface {
	GetAppBasic(ctx context.Context, appName string) (*fly.AppBasic, error)
	GetAppLogs(ctx context.Context, appName, token, region, instanceID string) (entries []fly.LogEntry, nextToken string, err error)
	wireguard.WebClient
}