object

package

v1.40.2 Latest Latest Go to latest Published: Apr 23, 2024 License: GPL-3.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/flipt-io/flipt

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func WithPollOptions(opts ...containers.Option[storagefs.Poller]) containers.Option[SnapshotStore]
func WithPrefix(prefix string) containers.Option[SnapshotStore]
type File
- func NewFile(key string, length int64, body io.ReadCloser, lastModified time.Time) *File
type FileInfo
- func NewFileInfo(name string, size int64, modTime time.Time) *FileInfo
type SnapshotStore
- func NewSnapshotStore(ctx context.Context, logger *zap.Logger, scheme string, bucket *gcblob.Bucket, ...) (*SnapshotStore, error)
- func (s *SnapshotStore) String() string
- func (s *SnapshotStore) View(_ context.Context, fn func(storage.ReadOnlyStore) error) error

Constants ¶

View Source

const S3Schema = "s3i"

S3Schema is a custom scheme for gocloud blob which works with how we interact with s3 (supports interfacing with minio)

Variables ¶

This section is empty.

Functions ¶

func WithPollOptions ¶

func WithPollOptions(opts ...containers.Option[storagefs.Poller]) containers.Option[SnapshotStore]

WithPollOptions configures the poller options used when periodically updating snapshot state

func WithPrefix ¶

func WithPrefix(prefix string) containers.Option[SnapshotStore]

WithPrefix configures the prefix for object store

Types ¶

type File ¶

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

func NewFile ¶

func NewFile(key string, length int64, body io.ReadCloser, lastModified time.Time) *File

func (*File) Close ¶

func (f *File) Close() error

func (*File) Read ¶

func (f *File) Read(p []byte) (int, error)

func (*File) Stat ¶

func (f *File) Stat() (fs.FileInfo, error)

type FileInfo ¶

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

func NewFileInfo ¶

func NewFileInfo(name string, size int64, modTime time.Time) *FileInfo

func (*FileInfo) Info ¶

func (fi *FileInfo) Info() (fs.FileInfo, error)

func (*FileInfo) IsDir ¶

func (fi *FileInfo) IsDir() bool

func (*FileInfo) ModTime ¶

func (fi *FileInfo) ModTime() time.Time

func (*FileInfo) Mode ¶

func (fi *FileInfo) Mode() fs.FileMode

func (*FileInfo) Name ¶

func (fi *FileInfo) Name() string

func (*FileInfo) SetDir ¶

func (fi *FileInfo) SetDir(v bool)

func (*FileInfo) Size ¶

func (fi *FileInfo) Size() int64

func (*FileInfo) Sys ¶

func (fi *FileInfo) Sys() any

func (*FileInfo) Type ¶

func (fi *FileInfo) Type() fs.FileMode

type SnapshotStore ¶

type SnapshotStore struct {
	*storagefs.Poller
	// contains filtered or unexported fields
}

func NewSnapshotStore ¶

func NewSnapshotStore(ctx context.Context, logger *zap.Logger, scheme string, bucket *gcblob.Bucket, opts ...containers.Option[SnapshotStore]) (*SnapshotStore, error)

func (*SnapshotStore) String ¶

func (s *SnapshotStore) String() string

func (*SnapshotStore) View ¶

func (s *SnapshotStore) View(_ context.Context, fn func(storage.ReadOnlyStore) error) error

View accepts a function which takes a *StoreSnapshot. The SnapshotStore will supply a snapshot which is valid for the lifetime of the provided function call.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL