storage

README

This package holds GCS Utlities

logging package

You can create a time based file that rollovers after max age

tr := gcs.NewTimeRotator(
		context.Background(),
		"web-logs",
		"message-events",
		"2006/01/20060102-1504",
		uuid.NewV4().String(),
		15*time.Minute,
	)

Documentation

Index

• type TimeRotator
  • func NewGCSTimeRotator(ctx context.Context, bkt string, path string, fileFmt string, uuid string, ...) *TimeRotator
  • func (bw *TimeRotator) Close() error
  • func (bw *TimeRotator) Write(e []byte) (int, error)

Types

type TimeRotator

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

TimeRotator stores relevant pointers to create and generator a writer

func NewGCSTimeRotator

func NewGCSTimeRotator(ctx context.Context, bkt string, path string, fileFmt string, uuid string, maxAge time.Duration) *TimeRotator

NewGCSTimeRotator returns a newly intitiated Writer

func (*TimeRotator) Close

func (bw *TimeRotator) Close() error

Close active blob

func (*TimeRotator) Write

func (bw *TimeRotator) Write(e []byte) (int, error)

Write adds the message to a queue to be written later