Documentation ¶
Index ¶
- Constants
- func FixupFargateConfig(vCpu, memoryMiB float64) (cpu CpuUnits, memory MemoryMiB)
- func GetLogStreamForTaskID(taskID string) string
- func GetTaskID(taskArn TaskArn) string
- func GetTaskStatus(ctx context.Context, taskArn TaskArn) error
- func PlatformToArchOS(platform string) (string, string)
- func SplitClusterTask(taskArn TaskArn) (string, string)
- func WaitForTask(ctx context.Context, taskArn TaskArn, poll time.Duration) error
- type AwsEcs
- func (a *AwsEcs) CreateUploadURL(ctx context.Context, name string) (string, error)
- func (a *AwsEcs) GetTaskArn(taskID string) (TaskArn, error)
- func (a *AwsEcs) GetVpcID() string
- func (a AwsEcs) Info(ctx context.Context, id TaskArn) (*types.TaskInfo, error)
- func (a *AwsEcs) MakeARN(service, resource string) string
- func (a *AwsEcs) PopulateVPCandSubnetID(ctx context.Context, vpcID, subnetID string) error
- func (a *AwsEcs) Run(ctx context.Context, env map[string]string, cmd ...string) (TaskArn, error)
- func (a AwsEcs) Stop(ctx context.Context, id types.TaskID) error
- func (a *AwsEcs) Tail(ctx context.Context, taskArn TaskArn) error
- func (a *AwsEcs) TailTaskID(ctx context.Context, taskID string) (EventStream, error)
- type CpuUnits
- type EventStream
- type LogEvent
- type LogGroupInput
- type LogStreamInfo
- type MemoryMiB
- type TaskArn
Constants ¶
View Source
const ( ContainerName = "main" DockerRegistry = "docker.io" EcrPublicRegistry = "public.ecr.aws" ProjectName = types.ProjectName )
View Source
const AwsLogsStreamPrefix = ProjectName
Variables ¶
This section is empty.
Functions ¶
func FixupFargateConfig ¶
func GetLogStreamForTaskID ¶
func PlatformToArchOS ¶
func SplitClusterTask ¶
Types ¶
type AwsEcs ¶
type AwsEcs struct { aws.Aws BucketName string ClusterName string LogGroupARN string SecurityGroupID string Spot bool SubNetID string TaskDefARN string VpcID string }
func (*AwsEcs) CreateUploadURL ¶
func (*AwsEcs) PopulateVPCandSubnetID ¶
func (*AwsEcs) TailTaskID ¶
type EventStream ¶
type EventStream interface { Close() error Events() <-chan types.StartLiveTailResponseStream }
EventStream is an interface that represents a stream of events from a call to StartLiveTail
func TailLogGroup ¶
func TailLogGroup(ctx context.Context, input LogGroupInput) (EventStream, error)
func TailLogGroups ¶
func TailLogGroups(ctx context.Context, since time.Time, logGroups ...LogGroupInput) (EventStream, error)
type LogEvent ¶
type LogEvent = types.LiveTailSessionLogEvent
func GetLogEvents ¶
func GetLogEvents(e types.StartLiveTailResponseStream) ([]LogEvent, error)
type LogGroupInput ¶
type LogGroupInput struct { LogGroupARN string LogStreamNames []string LogStreamNamePrefix string LogEventFilterPattern string }
LogGroupInput is like cloudwatchlogs.StartLiveTailInput but with only one loggroup and one logstream prefix.
type LogStreamInfo ¶
func GetLogStreamInfo ¶
func GetLogStreamInfo(logStream string) *LogStreamInfo
Source Files ¶
Click to show internal directories.
Click to hide internal directories.