server

Documentation

Index

• type AggregateBucket
• type BucketClassRegistry
• type BucketConfig
• type Options
• type Server
  • func New(cfg *rest.Config, opts Options) (*Server, error)
  • func (s *Server) CreateBucket(ctx context.Context, req *ori.CreateBucketRequest) (res *ori.CreateBucketResponse, retErr error)
  • func (s *Server) DeleteBucket(ctx context.Context, req *ori.DeleteBucketRequest) (*ori.DeleteBucketResponse, error)
  • func (s *Server) ListBucketClasses(ctx context.Context, req *ori.ListBucketClassesRequest) (*ori.ListBucketClassesResponse, error)
  • func (s *Server) ListBuckets(ctx context.Context, req *ori.ListBucketsRequest) (*ori.ListBucketsResponse, error)

Types

type AggregateBucket

type AggregateBucket struct {
	BucketClaim  *objectbucketv1alpha1.ObjectBucketClaim
	AccessSecret *corev1.Secret
}

type BucketClassRegistry

type BucketClassRegistry interface {
	Get(volumeClassName string) (*ori.BucketClass, bool)
	List() []*ori.BucketClass
}

type BucketConfig

type BucketConfig struct {
	BucketClaim *objectbucketv1alpha1.ObjectBucketClaim
}

type Options

type Options struct {
	IDGen idgen.IDGen

	Namespace                  string
	BucketEndpoint             string
	BucketPoolStorageClassName string
	BucketClassSelector        map[string]string
}

type Server

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

func New

func New(cfg *rest.Config, opts Options) (*Server, error)

func (*Server) CreateBucket

func (s *Server) CreateBucket(ctx context.Context, req *ori.CreateBucketRequest) (res *ori.CreateBucketResponse, retErr error)

func (*Server) DeleteBucket

func (s *Server) DeleteBucket(ctx context.Context, req *ori.DeleteBucketRequest) (*ori.DeleteBucketResponse, error)

func (*Server) ListBucketClasses

func (s *Server) ListBucketClasses(ctx context.Context, req *ori.ListBucketClassesRequest) (*ori.ListBucketClassesResponse, error)

func (*Server) ListBuckets

func (s *Server) ListBuckets(ctx context.Context, req *ori.ListBucketsRequest) (*ori.ListBucketsResponse, error)