accesslogs

Aug 20, 2024

Changes in this version

type StorjStorage

+ func NewStorjStorage(access *uplink.Access) *StorjStorage

+ func (s StorjStorage) SerializedAccessGrant() (string, error)

Jul 11, 2024

Changes in this version

+ type S3AccessLogEntry struct

+ func NewS3AccessLogEntry(o S3AccessLogEntryOptions) *S3AccessLogEntry

+ func (e S3AccessLogEntry) Size() memory.Size

+ func (e S3AccessLogEntry) String() string

+ type S3AccessLogEntryOptions struct

+ ACLRequired string

+ AccessPointARN string

+ AuthenticationType string

+ Bucket string

+ BucketOwner string

+ BytesSent int

+ CipherSuite string

+ ErrorCode string

+ HTTPStatus int

+ HostHeader string

+ HostID string

+ Key string

+ ObjectSize *int

+ Operation string

+ Referer string

+ RemoteIP string

+ RequestID string

+ RequestURI string

+ Requester string

+ SignatureVersion string

+ TLSVersion string

+ Time time.Time

+ TotalTime time.Duration

+ TurnAroundTime time.Duration

+ UserAgent string

+ VersionID string

Jul 2, 2024

Changes in this version

+ var ErrClosed = errors.New("closed")

+ var ErrQueueLimit = errors.New("upload queue limit reached")

+ var ErrTooLarge = errors.New("entry too large")

+ var Error = errs.Class("accesslogs")

+ type Entry interface

+ Size func() memory.Size

+ String func() string

+ type Key struct

+ Bucket string

+ Prefix string

+ PublicProjectID uuid.UUID

+ type Options struct

+ DefaultEntryLimit memory.Size

+ DefaultShipmentLimit memory.Size

+ UploadingOptions struct{ ... }

+ type Processor struct

+ func NewProcessor(log *zap.Logger, opts Options) *Processor

+ func (p *Processor) Close() (err error)

+ func (p *Processor) QueueEntry(store Storage, key Key, entry Entry) (err error)

+ func (p *Processor) Run() error

+ type Storage interface

+ Put func(ctx context.Context, bucket, key string, body []byte) error

+ type StorjStorage struct

+ func (s StorjStorage) Put(ctx context.Context, bucket, key string, body []byte) (err error)