logs

Documentation

Index

• type Client
  • func NewLogsClient(conf config.Config, logger flotillaLog.Logger, name string) (Client, error)
• type EKSCloudWatchLog
• type EKSCloudWatchLogsClient
  • func (lc *EKSCloudWatchLogsClient) Initialize(conf config.Config) error
  • func (lc *EKSCloudWatchLogsClient) Logs(executable state.Executable, run state.Run, lastSeen *string, role *string, ...) (string, *string, error)
  • func (lc *EKSCloudWatchLogsClient) LogsText(executable state.Executable, run state.Run, w http.ResponseWriter) error
  • func (lc *EKSCloudWatchLogsClient) Name() string
• type EKSS3LogsClient
  • func (lc *EKSS3LogsClient) Initialize(conf config.Config) error
  • func (lc *EKSS3LogsClient) Logs(executable state.Executable, run state.Run, lastSeen *string, role *string, ...) (string, *string, error)
  • func (lc *EKSS3LogsClient) LogsText(executable state.Executable, run state.Run, w http.ResponseWriter) error
  • func (lc *EKSS3LogsClient) Name() string

Types

type Client

type Client interface {
	Name() string
	Initialize(config config.Config) error
	Logs(executable state.Executable, run state.Run, lastSeen *string, role *string, facility *string) (string, *string, error)
	LogsText(executable state.Executable, run state.Run, w http.ResponseWriter) error
}

Client returns logs for a Run

func NewLogsClient

func NewLogsClient(conf config.Config, logger flotillaLog.Logger, name string) (Client, error)

NewLogsClient creates and initializes a run logs client

type EKSCloudWatchLog

type EKSCloudWatchLog struct {
	Log string `json:"log"`
}

type EKSCloudWatchLogsClient

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

EKSCloudWatchLogsClient corresponds with the aws logs driver for ECS and returns logs for runs

func (*EKSCloudWatchLogsClient) Initialize

func (lc *EKSCloudWatchLogsClient) Initialize(conf config.Config) error

Initialize sets up the EKSCloudWatchLogsClient

func (*EKSCloudWatchLogsClient) Logs

func (lc *EKSCloudWatchLogsClient) Logs(executable state.Executable, run state.Run, lastSeen *string, role *string, facility *string) (string, *string, error)

Logs returns all logs from the log stream identified by handle since lastSeen

func (*EKSCloudWatchLogsClient) LogsText

func (lc *EKSCloudWatchLogsClient) LogsText(executable state.Executable, run state.Run, w http.ResponseWriter) error

This method doesn't return log string, it is a placeholder only.

func (*EKSCloudWatchLogsClient) Name

func (lc *EKSCloudWatchLogsClient) Name() string

Name returns the name of the logs client

type EKSS3LogsClient

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

EKSS3LogsClient corresponds with the aws logs driver for ECS and returns logs for runs

func (*EKSS3LogsClient) Initialize

func (lc *EKSS3LogsClient) Initialize(conf config.Config) error

Initialize sets up the EKSS3LogsClient

func (*EKSS3LogsClient) Logs

func (lc *EKSS3LogsClient) Logs(executable state.Executable, run state.Run, lastSeen *string, role *string, facility *string) (string, *string, error)

func (*EKSS3LogsClient) LogsText

func (lc *EKSS3LogsClient) LogsText(executable state.Executable, run state.Run, w http.ResponseWriter) error

Logs returns all logs from the log stream identified by handle since lastSeen

func (*EKSS3LogsClient) Name

func (lc *EKSS3LogsClient) Name() string

Name returns the name of the logs client