Documentation
¶
Index ¶
- func IsUsed(md *meta.Data) bool
- type ClusterManager
- func (cm *ClusterManager) BaseDir(ns namespace.ID) (string, error)
- func (cm *ClusterManager) CanDeleteNamespace(ctx context.Context, app *apps.Instance, ns *namespace.Namespace) error
- func (cm *ClusterManager) DeleteNamespace(ctx context.Context, app *apps.Instance, ns *namespace.Namespace) error
- func (cm *ClusterManager) PersistentStoreFallback(id string) (gcsemu.Store, bool)
- type Fallback
- type PublicBucketServer
- func (s *PublicBucketServer) BaseAddr() string
- func (s *PublicBucketServer) Deregister(namespace string)
- func (s *PublicBucketServer) Register(namespace string, store gcsemu.Store)
- func (s *PublicBucketServer) Serve(ln net.Listener) error
- func (s *PublicBucketServer) ServeHTTP(w http.ResponseWriter, req *http.Request)
- type Server
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ClusterManager ¶
type ClusterManager struct {
// contains filtered or unexported fields
}
func NewClusterManager ¶
func NewClusterManager(ns *namespace.Manager) *ClusterManager
NewClusterManager creates a new ClusterManager.
func (*ClusterManager) CanDeleteNamespace ¶
func (cm *ClusterManager) CanDeleteNamespace(ctx context.Context, app *apps.Instance, ns *namespace.Namespace) error
CanDeleteNamespace implements namespace.DeletionHandler.
func (*ClusterManager) DeleteNamespace ¶
func (cm *ClusterManager) DeleteNamespace(ctx context.Context, app *apps.Instance, ns *namespace.Namespace) error
DeleteNamespace implements namespace.DeletionHandler.
func (*ClusterManager) PersistentStoreFallback ¶ added in v1.44.6
func (cm *ClusterManager) PersistentStoreFallback(id string) (gcsemu.Store, bool)
PersistentStoreFallback is a public server fallback handler for resolving stores based on the cluster manager's base directory.
type Fallback ¶ added in v1.44.6
Fallback is a function that returns a store for a given namespace. It is used for resolving namespace ids to stores, where the store is not pre-registered by Register.
type PublicBucketServer ¶ added in v1.44.6
type PublicBucketServer struct {
// contains filtered or unexported fields
}
func NewPublicBucketServer ¶ added in v1.44.6
func NewPublicBucketServer(baseAddr string, fallback Fallback) *PublicBucketServer
NewPublicBucketServer creates a new PublicBucketServer. If fallback is nil, no fallback will be used.
func (*PublicBucketServer) BaseAddr ¶ added in v1.44.6
func (s *PublicBucketServer) BaseAddr() string
func (*PublicBucketServer) Deregister ¶ added in v1.44.6
func (s *PublicBucketServer) Deregister(namespace string)
func (*PublicBucketServer) Register ¶ added in v1.44.6
func (s *PublicBucketServer) Register(namespace string, store gcsemu.Store)
func (*PublicBucketServer) Serve ¶ added in v1.44.6
func (s *PublicBucketServer) Serve(ln net.Listener) error
func (*PublicBucketServer) ServeHTTP ¶ added in v1.44.6
func (s *PublicBucketServer) ServeHTTP(w http.ResponseWriter, req *http.Request)
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func NewDirServer ¶
func NewDirServer(public *PublicBucketServer, nsID namespace.ID, baseDir string) *Server
func NewInMemoryServer ¶
func NewInMemoryServer(public *PublicBucketServer) *Server
func (*Server) Emu ¶ added in v1.58.0
Emu returns the emulator serving this store, for the operations that need Cloud Storage semantics rather than a bare store.
func (*Server) PublicBaseURL ¶ added in v1.44.6
Source Files
Click to show internal directories.
Click to hide internal directories.