upload

Documentation

Index

• type ContextEnvelope
• type ContextMetadata
• type S3Uploader
  • func NewS3Uploader(...) *S3Uploader
  • func (u *S3Uploader) Upload(ctx context.Context, filePath string, metadata ContextMetadata) error

Types

type ContextEnvelope

type ContextEnvelope struct {
	Metadata ContextMetadata `json:"metadata"`
	Payload  json.RawMessage `json:"payload"`
}

ContextEnvelope wraps the uploaded payload with metadata.

type ContextMetadata

type ContextMetadata struct {
	ContextType string `json:"contextType"`
	Repository  string `json:"repository"`
	Branch      string `json:"branch,omitempty"`
	Environment string `json:"environment,omitempty"`
	Name        string `json:"name"`
	PRNumber    int    `json:"prNumber,omitempty"`
	FromPR      int    `json:"fromPR,omitempty"`
	CommitSHA   string `json:"commitSha,omitempty"`
	UploadedAt  string `json:"uploadedAt"`
	CLIVersion  string `json:"cliVersion"`
}

ContextMetadata contains metadata about the context upload.

type S3Uploader

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

S3Uploader uploads context data to S3 using temporary credentials.

func NewS3Uploader

func NewS3Uploader(accessKeyID, secretAccessKey, sessionToken, region, bucket, keyPrefix, kmsKeyARN string) *S3Uploader

NewS3Uploader creates a new S3 uploader with the given temporary credentials.

func (*S3Uploader) Upload

func (u *S3Uploader) Upload(ctx context.Context, filePath string, metadata ContextMetadata) error

Upload reads the file, wraps it in an envelope, and uploads to S3 as latest.json and history/{timestamp}.json.