storage

package
v1.55.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 28, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BucketName

type BucketName = string

type LocalStorageService

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

LocalStorageService - A local implementation of the storage and listeners services, bypasses the gateway to forward storage change events directly to listeners.

func NewLocalStorageService

func NewLocalStorageService(opts StorageOptions) (*LocalStorageService, error)

func (*LocalStorageService) Delete

func (*LocalStorageService) Exists

func (*LocalStorageService) GetListeners

func (r *LocalStorageService) GetListeners() map[BucketName]map[serviceName]int

func (*LocalStorageService) HandleRequest

func (*LocalStorageService) Listen

func (*LocalStorageService) Read

TODO: If we move declare here, we can stop attempting to lazily create buckets in the storage service

func (*LocalStorageService) SubscribeToState

func (s *LocalStorageService) SubscribeToState(fn func(State))

func (*LocalStorageService) WorkerCount

func (r *LocalStorageService) WorkerCount() int

func (*LocalStorageService) Write

type State

type State = map[BucketName]map[serviceName]int

type StorageOptions

type StorageOptions struct {
	AccessKey string
	SecretKey string
}

Jump to

Keyboard shortcuts

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