pkg

Documentation

Index

• func NewDriver(ctx context.Context, provisioner, minioHost, accessKey, secretKey string) (*IdentityServer, *ProvisionerServer, error)
• type IdentityServer
  • func (id *IdentityServer) ProvisionerGetInfo(ctx context.Context, req *cosi.ProvisionerGetInfoRequest) (*cosi.ProvisionerGetInfoResponse, error)
• type ProvisionerServer
  • func (s *ProvisionerServer) ProvisionerCreateBucket(ctx context.Context, req *cosi.ProvisionerCreateBucketRequest) (*cosi.ProvisionerCreateBucketResponse, error)
  • func (s *ProvisionerServer) ProvisionerDeleteBucket(ctx context.Context, req *cosi.ProvisionerDeleteBucketRequest) (*cosi.ProvisionerDeleteBucketResponse, error)
  • func (s *ProvisionerServer) ProvisionerGrantBucketAccess(ctx context.Context, req *cosi.ProvisionerGrantBucketAccessRequest) (*cosi.ProvisionerGrantBucketAccessResponse, error)
  • func (s *ProvisionerServer) ProvisionerRevokeBucketAccess(ctx context.Context, req *cosi.ProvisionerRevokeBucketAccessRequest) (*cosi.ProvisionerRevokeBucketAccessResponse, error)

Functions

func NewDriver

func NewDriver(ctx context.Context, provisioner, minioHost, accessKey, secretKey string) (*IdentityServer, *ProvisionerServer, error)

Types

type IdentityServer

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

func (*IdentityServer) ProvisionerGetInfo

func (id *IdentityServer) ProvisionerGetInfo(ctx context.Context,
	req *cosi.ProvisionerGetInfoRequest) (*cosi.ProvisionerGetInfoResponse, error)

type ProvisionerServer

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

func (*ProvisionerServer) ProvisionerCreateBucket

func (s *ProvisionerServer) ProvisionerCreateBucket(ctx context.Context,
	req *cosi.ProvisionerCreateBucketRequest) (*cosi.ProvisionerCreateBucketResponse, error)

ProvisionerCreateBucket is an idempotent method for creating buckets It is expected to create the same bucket given a bucketName and protocol If the bucket already exists, then it MUST return codes.AlreadyExists Return values

nil -                   Bucket successfully created
codes.AlreadyExists -   Bucket already exists. No more retries
non-nil err -           Internal error                                [requeue'd with exponential backoff]

func (*ProvisionerServer) ProvisionerDeleteBucket

func (s *ProvisionerServer) ProvisionerDeleteBucket(ctx context.Context,
	req *cosi.ProvisionerDeleteBucketRequest) (*cosi.ProvisionerDeleteBucketResponse, error)

func (*ProvisionerServer) ProvisionerGrantBucketAccess

func (s *ProvisionerServer) ProvisionerGrantBucketAccess(ctx context.Context,
	req *cosi.ProvisionerGrantBucketAccessRequest) (*cosi.ProvisionerGrantBucketAccessResponse, error)

func (*ProvisionerServer) ProvisionerRevokeBucketAccess

func (s *ProvisionerServer) ProvisionerRevokeBucketAccess(ctx context.Context,
	req *cosi.ProvisionerRevokeBucketAccessRequest) (*cosi.ProvisionerRevokeBucketAccessResponse, error)