awsinspect

Documentation

Index

• func TailLogStream(ctx context.Context, client CloudwatchLogsClient, logGroup LogStream, ...) error
• type CloudwatchLogsClient
• type ECSClient
• type FormationClient
• type LogStream
  • func GetAllLogStreams(ctx context.Context, ecsClient ECSClient, serviceSummary *ServiceSummary) ([]LogStream, error)
• type ServiceSummary
  • func GetStackServices(ctx context.Context, client FormationClient, stackName string) (*ServiceSummary, error)

Functions

func TailLogStream

func TailLogStream(ctx context.Context, client CloudwatchLogsClient, logGroup LogStream, fromTime time.Time, callback func(context.Context, LogStream, string)) error

Types

type CloudwatchLogsClient

type CloudwatchLogsClient interface {
	GetLogEvents(ctx context.Context, params *cloudwatchlogs.GetLogEventsInput, optFns ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.GetLogEventsOutput, error)
}

type ECSClient

type ECSClient interface {
	DescribeServices(ctx context.Context, input *ecs.DescribeServicesInput, opts ...func(*ecs.Options)) (*ecs.DescribeServicesOutput, error)
	ListTasks(ctx context.Context, input *ecs.ListTasksInput, opts ...func(*ecs.Options)) (*ecs.ListTasksOutput, error)
	DescribeTasks(ctx context.Context, input *ecs.DescribeTasksInput, opts ...func(*ecs.Options)) (*ecs.DescribeTasksOutput, error)
	DescribeTaskDefinition(ctx context.Context, input *ecs.DescribeTaskDefinitionInput, opts ...func(*ecs.Options)) (*ecs.DescribeTaskDefinitionOutput, error)
}

type FormationClient

type FormationClient interface {
	DescribeStackResources(ctx context.Context, input *cloudformation.DescribeStackResourcesInput, opts ...func(*cloudformation.Options)) (*cloudformation.DescribeStackResourcesOutput, error)
	DescribeStacks(ctx context.Context, input *cloudformation.DescribeStacksInput, opts ...func(*cloudformation.Options)) (*cloudformation.DescribeStacksOutput, error)
}

type LogStream

type LogStream struct {
	Container string
	LogGroup  string
	LogStream string
}

func GetAllLogStreams

func GetAllLogStreams(ctx context.Context, ecsClient ECSClient, serviceSummary *ServiceSummary) ([]LogStream, error)

type ServiceSummary

type ServiceSummary struct {
	ClusterName string
	ServiceARNs []string
}

func GetStackServices

func GetStackServices(ctx context.Context, client FormationClient, stackName string) (*ServiceSummary, error)