Documentation ¶
Index ¶
- type AWSClient
- type AWSTee
- type AWSTeeReader
- type CloudwatchLogsClient
- type CloudwatchLogsConfig
- type Config
- func (cfg *Config) EnableCloudwatchLogs() bool
- func (cfg *Config) EnableS3() bool
- func (cfg *Config) EndpointResolver() (aws.EndpointResolver, bool)
- func (cfg *Config) Load(path string) error
- func (cfg *Config) Restrict() error
- func (cfg *Config) SetFlags(f *flag.FlagSet)
- func (cfg *Config) ValidateVersion(version string) error
- type EndpointsConfig
- type S3Client
- type S3Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AWSClient ¶
type AWSClient struct { S3 S3Client CloudwatchLogs CloudwatchLogsClient }
type AWSTeeReader ¶
type AWSTeeReader struct {
// contains filtered or unexported fields
}
func (*AWSTeeReader) Close ¶
func (t *AWSTeeReader) Close() error
type CloudwatchLogsClient ¶
type CloudwatchLogsClient interface { DescribeLogStreams(ctx context.Context, params *cloudwatchlogs.DescribeLogStreamsInput, optFns ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.DescribeLogStreamsOutput, error) PutLogEvents(ctx context.Context, input *cloudwatchlogs.PutLogEventsInput, optFns ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.PutLogEventsOutput, error) CreateLogGroup(ctx context.Context, input *cloudwatchlogs.CreateLogGroupInput, optFns ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.CreateLogGroupOutput, error) CreateLogStream(ctx context.Context, input *cloudwatchlogs.CreateLogStreamInput, optFns ...func(*cloudwatchlogs.Options)) (*cloudwatchlogs.CreateLogStreamOutput, error) }
type CloudwatchLogsConfig ¶
type CloudwatchLogsConfig struct { LogGroup string `yaml:"log_group,omitempty"` FlushInterval string `yaml:"flush_interval,omitempty"` BufferLines int `yaml:"buffer_lines,omitempty"` CreateLogGroup bool `yaml:"create_log_group,omitempty"` // contains filtered or unexported fields }
func (*CloudwatchLogsConfig) Restrict ¶
func (cfg *CloudwatchLogsConfig) Restrict() error
func (*CloudwatchLogsConfig) SetFlags ¶
func (cfg *CloudwatchLogsConfig) SetFlags(f *flag.FlagSet)
type Config ¶
type Config struct { RequiredVersion string `yaml:"required_version,omitempty"` AWSRegion string `yaml:"aws_region,omitempty"` S3 *S3Config `yaml:"s3,omitempty"` Cloudwatch *CloudwatchLogsConfig `yaml:"cloudwatch,omitempty"` Endpoints *EndpointsConfig `yaml:"endpoints,omitempty"` // contains filtered or unexported fields }
func DefaultConfig ¶
func DefaultConfig() *Config
func (*Config) EnableCloudwatchLogs ¶
func (*Config) EndpointResolver ¶
func (cfg *Config) EndpointResolver() (aws.EndpointResolver, bool)
func (*Config) ValidateVersion ¶
ValidateVersion validates a version satisfies required_version.
type EndpointsConfig ¶
type S3Client ¶
type S3Client interface { s3.HeadObjectAPIClient manager.UploadAPIClient }
Click to show internal directories.
Click to hide internal directories.