processor

Documentation

Index

• type Processor
  • func NewProcessor(s3ClientRead, s3ClientWrite *s3.S3, modelInvocation *model.MetadataGenerator, ...) *Processor
  • func (p *Processor) ProcessModelInvocationLogS3Object(sourceKey string, logProcessorFunc func([]byte) ([]byte, error)) ([]byte, error)
  • func (p *Processor) ProcessModelInvocationLogs(accountID, region, modelInvocationLogsInputBucketPrefix string, ...) error

Types

type Processor

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

func NewProcessor

func NewProcessor(s3ClientRead, s3ClientWrite *s3.S3, modelInvocation *model.MetadataGenerator, modelInvocationLogsInputBucket, metadataLogsOutputBucket string) *Processor

func (*Processor) ProcessModelInvocationLogS3Object

func (p *Processor) ProcessModelInvocationLogS3Object(sourceKey string, logProcessorFunc func([]byte) ([]byte, error)) ([]byte, error)

func (*Processor) ProcessModelInvocationLogs

func (p *Processor) ProcessModelInvocationLogs(accountID, region, modelInvocationLogsInputBucketPrefix string, year, month, day, hour int) error