ecslogging

Documentation

Overview

Package ecslogging contains utility functions for ECS logging.

Package ecslogging contains utility functions for ECS logging.

Package ecslogging contains utility functions for ECS logging.

Index

• func WriteHumanLogs(w io.Writer, logStringers []HumanJSONStringer) error
• func WriteJSONLogs(w io.Writer, logStringers []HumanJSONStringer) error
• type HumanJSONStringer
• type ServiceClient
  • func NewServiceClient(sess *session.Session, app, env, svc string) *ServiceClient
  • func (s *ServiceClient) WriteLogEvents(opts WriteLogEventsOpts) error
• type TaskClient
  • func NewTaskClient(sess *session.Session, groupName string, tasks []*task.Task) *TaskClient
  • func (t *TaskClient) WriteEventsUntilStopped() error
• type TasksDescriber
• type WriteLogEventsOpts

Functions

func WriteHumanLogs

func WriteHumanLogs(w io.Writer, logStringers []HumanJSONStringer) error

WriteHumanLogs outputs CloudWatch logs in human-readable format.

func WriteJSONLogs

func WriteJSONLogs(w io.Writer, logStringers []HumanJSONStringer) error

WriteJSONLogs outputs CloudWatch logs in JSON format.

Types

type HumanJSONStringer

type HumanJSONStringer interface {
	HumanString() string
	JSONString() (string, error)
}

HumanJSONStringer can output in both human-readable and JSON format.

type ServiceClient

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

ServiceClient retrieves the logs of an Amazon ECS service.

func NewServiceClient

func NewServiceClient(sess *session.Session, app, env, svc string) *ServiceClient

NewServiceClient returns a ServiceClient for the svc service under env and app. The logging client is initialized from the given sess session.

func (*ServiceClient) WriteLogEvents

func (s *ServiceClient) WriteLogEvents(opts WriteLogEventsOpts) error

WriteLogEvents writes service logs.

type TaskClient

type TaskClient struct {
	GroupName string
	Tasks     []*task.Task

	Writer       io.Writer
	EventsLogger logGetter
	Describer    TasksDescriber
}

TaskClient retrieves the logs of Amazon ECS tasks.

func NewTaskClient

func NewTaskClient(sess *session.Session, groupName string, tasks []*task.Task) *TaskClient

NewTaskClient returns a TaskClient that can retrieve logs from the given tasks under the groupName.

func (*TaskClient) WriteEventsUntilStopped

func (t *TaskClient) WriteEventsUntilStopped() error

WriteEventsUntilStopped writes tasks' events to a writer until all tasks have stopped.

type TasksDescriber

type TasksDescriber interface {
	DescribeTasks(cluster string, taskARNs []string) ([]*ecs.Task, error)
}

TasksDescriber describes ECS tasks.

type WriteLogEventsOpts

type WriteLogEventsOpts struct {
	Follow    bool
	Limit     *int64
	StartTime *int64
	EndTime   *int64
	TaskIDs   []string
	// OnEvents is a handler that's invoked when logs are retrieved from the service.
	OnEvents func(w io.Writer, logs []HumanJSONStringer) error
}

WriteLogEventsOpts wraps the parameters to call WriteLogEvents.