s3storage

Jun 6, 2020

Changes in this version

+ type S3Event struct

+ Records []S3EventRecord

+ func (p *S3Event) Unmarshal(data []byte) error

+ type S3EventRecord struct

+ AwsRegion string

+ EventName string

+ EventSource string

+ EventTime string

+ EventVersion string

+ RequestParameters map[string]string

+ ResponseElements map[string]string

+ S3 S3EventRecordData

+ UserIdentity S3EventRecordIdentity

+ type S3EventRecordData struct

+ Bucket S3EventRecordDataBucket

+ ConfigurationId string

+ Object S3EventRecordDataObject

+ S3SchemaVersion string

+ type S3EventRecordDataBucket struct

+ Arn string

+ Name string

+ OwnerIdentity S3EventRecordIdentity

+ type S3EventRecordDataObject struct

+ ETag string

+ Key string

+ Sequencer string

+ Size int

+ VersionID string

+ type S3EventRecordIdentity struct

+ PrincipalId string

type Service

+ func (s *Service) Close() error

+ func (s *Service) InitializeSQS(handler func(msg string) error) error

Jun 3, 2020

Changes in this version

+ type Service struct

+ func New(bucketName string, tracer tracing.Tracer) (*Service, error)

+ func (f *Service) ArtifactExists(ctx context.Context, service, artifactID string) (bool, error)

+ func (f *Service) ArtifactPaths(ctx context.Context, service string, environment string, branch string, ...) (specPath string, resourcesPath string, close func(context.Context), err error)

+ func (f *Service) ArtifactSpecification(ctx context.Context, service string, artifactID string) (artifact.Spec, error)

+ func (f *Service) ArtifactSpecifications(ctx context.Context, service string, n int) ([]artifact.Spec, error)

+ func (f *Service) LatestArtifactPaths(ctx context.Context, service string, environment string, branch string) (specPath string, resourcesPath string, close func(context.Context), err error)

+ func (f *Service) LatestArtifactSpecification(ctx context.Context, service string, branch string) (artifact.Spec, error)

+ func (s *Service) CreateArtifact(artifactSpec artifact.Spec, md5 string) (string, error)

+ func (s *Service) InitializeBucket() error