gcspersist

Documentation

Index

• type ReadWriter
  • func NewReadWriter(settings func() StorageSettings, now func() time.Time) *ReadWriter
  • func (this *ReadWriter) Name() string
  • func (this *ReadWriter) Read(document projector.Document) error
  • func (this *ReadWriter) ReadPanic(document projector.Document)
  • func (this *ReadWriter) Write(document projector.Document) error
• type StorageSettings

Types

type ReadWriter

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

func NewReadWriter

func NewReadWriter(settings func() StorageSettings, now func() time.Time) *ReadWriter

func (*ReadWriter) Name

func (this *ReadWriter) Name() string

func (*ReadWriter) Read

func (this *ReadWriter) Read(document projector.Document) error

func (*ReadWriter) ReadPanic

func (this *ReadWriter) ReadPanic(document projector.Document)

func (*ReadWriter) Write

func (this *ReadWriter) Write(document projector.Document) error

type StorageSettings

type StorageSettings struct {
	HTTPClient  persist.HTTPClient
	BucketName  string
	PathPrefix  string
	Context     context.Context
	Credentials gcs.Credentials
}