bucketserver

Documentation

Index

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

Types

type BucketClassRegistry

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

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, bucketClassRegistry BucketClassRegistry, opts Options) (*Server, error)

func (*Server) CreateBucket

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

func (*Server) DeleteBucket

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

func (*Server) ListBucketClasses

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

func (*Server) ListBuckets

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

func (*Server) ListEvents

func (s *Server) ListEvents(ctx context.Context, req *iri.ListEventsRequest) (*iri.ListEventsResponse, error)