objects

Documentation

Index

• func IsUsed(md *meta.Data) bool
• type ClusterManager
  • func NewClusterManager(ns *namespace.Manager) *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 NewPublicBucketServer(baseAddr string, fallback Fallback) *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
  • func NewDirServer(public *PublicBucketServer, nsID namespace.ID, baseDir string) *Server
  • func NewInMemoryServer(public *PublicBucketServer) *Server
  • func (s *Server) Endpoint() string
  • func (s *Server) Initialize(md *meta.Data) error
  • func (s *Server) PublicBaseURL() string
  • func (s *Server) Start() error
  • func (s *Server) Stop()

Functions

func IsUsed

func IsUsed(md *meta.Data) bool

IsUsed reports whether the application uses object storage at all.

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) BaseDir

func (cm *ClusterManager) BaseDir(ns namespace.ID) (string, error)

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

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

type Fallback func(namespace string) (gcsemu.Store, bool)

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

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

func NewPublicBucketServer

func NewPublicBucketServer(baseAddr string, fallback Fallback) *PublicBucketServer

NewPublicBucketServer creates a new PublicBucketServer. If fallback is nil, no fallback will be used.

func (*PublicBucketServer) BaseAddr

func (s *PublicBucketServer) BaseAddr() string

func (*PublicBucketServer) Deregister

func (s *PublicBucketServer) Deregister(namespace string)

func (*PublicBucketServer) Register

func (s *PublicBucketServer) Register(namespace string, store gcsemu.Store)

func (*PublicBucketServer) Serve

func (s *PublicBucketServer) Serve(ln net.Listener) error

func (*PublicBucketServer) ServeHTTP

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) Endpoint

func (s *Server) Endpoint() string

func (*Server) Initialize

func (s *Server) Initialize(md *meta.Data) error

func (*Server) PublicBaseURL

func (s *Server) PublicBaseURL() string

func (*Server) Start

func (s *Server) Start() error

func (*Server) Stop

func (s *Server) Stop()