server

Documentation

Index

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

Constants

const (
	InvolvedObjectKind               = "Bucket"
	InvolvedObjectKindSelector       = "involvedObject.kind"
	InvolvedObjectAPIVersionSelector = "involvedObject.apiVersion"
)

Types

type AggregateIronCoreBucket

type AggregateIronCoreBucket struct {
	Bucket       *storagev1alpha1.Bucket
	AccessSecret *corev1.Secret
}

type Options

type Options struct {
	// BrokerDownwardAPILabels specifies which labels to broker via downward API and what the default
	// label name is to obtain the value in case there is no value for the downward API.
	// Example usage is e.g. to broker the root UID (map "root-bucket-uid" to bucketpoollet's
	// "bucketpoollet.ironcore.dev/bucket-uid")
	BrokerDownwardAPILabels map[string]string
	Namespace               string
	BucketPoolName          string
	BucketPoolSelector      map[string]string
}

type Server

type Server struct {
	iri.UnimplementedBucketRuntimeServer
	// 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 *iri.CreateBucketRequest) (res *iri.CreateBucketResponse, retErr error)

func (*Server) DeleteBucket

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

func (*Server) ListBucketClasses

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

func (*Server) ListBuckets

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

func (*Server) ListEvents

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

func (*Server) Version

func (s *Server) Version(ctx context.Context, req *iri.VersionRequest) (*iri.VersionResponse, error)