storage

Documentation

Index

• type Handler
  • func New(p storageParams) *Handler
  • func (h *Handler) Build(opts ...connect.HandlerOption) (string, http.Handler)
  • func (h *Handler) CopyObject(ctx context.Context, req *connect.Request[storage.CopyObjectRequest]) (*connect.Response[storage.CopyObjectResponse], error)
  • func (h *Handler) CreateBucket(ctx context.Context, req *connect.Request[storage.CreateBucketRequest]) (*connect.Response[storage.CreateBucketResponse], error)
  • func (h Handler) CreateProvider(ctx context.Context, req *connect.Request[storage.CreateProviderRequest]) (*connect.Response[storage.CreateProviderResponse], error)
  • func (h *Handler) DeleteBucket(ctx context.Context, req *connect.Request[storage.DeleteBucketRequest]) (*connect.Response[storage.DeleteBucketResponse], error)
  • func (h *Handler) DeleteObject(ctx context.Context, req *connect.Request[storage.DeleteObjectRequest]) (*connect.Response[storage.DeleteObjectResponse], error)
  • func (h Handler) DeleteProvider(ctx context.Context, req *connect.Request[storage.DeleteProviderRequest]) (*connect.Response[storage.DeleteProviderResponse], error)
  • func (h *Handler) DownloadObject(ctx context.Context, req *connect.Request[storage.DownloadObjectRequest], ...) error
  • func (h *Handler) GetBucket(ctx context.Context, req *connect.Request[storage.GetBucketRequest]) (*connect.Response[storage.GetBucketResponse], error)
  • func (h *Handler) GetObject(ctx context.Context, req *connect.Request[storage.GetObjectRequest]) (*connect.Response[storage.GetObjectResponse], error)
  • func (h Handler) GetProvider(ctx context.Context, req *connect.Request[storage.GetProviderRequest]) (*connect.Response[storage.GetProviderResponse], error)
  • func (h *Handler) ListBuckets(ctx context.Context, req *connect.Request[storage.ListBucketsRequest]) (*connect.Response[storage.ListBucketsResponse], error)
  • func (h *Handler) ListObjects(ctx context.Context, req *connect.Request[storage.ListObjectsRequest]) (*connect.Response[storage.ListObjectsResponse], error)
  • func (h Handler) ListProviders(ctx context.Context, req *connect.Request[storage.ListProvidersRequest]) (*connect.Response[storage.ListProvidersResponse], error)
  • func (h Handler) LookupProvider(ctx context.Context, req *connect.Request[storage.LookupProviderRequest]) (*connect.Response[storage.LookupProviderResponse], error)
  • func (h *Handler) ServiceName() string
  • func (h Handler) UnlinkBucket(ctx context.Context, req *connect.Request[storage.UnlinkBucketRequest]) (*connect.Response[storage.UnlinkBucketResponse], error)
  • func (h *Handler) UploadObject(ctx context.Context, stream *connect.ClientStream[storage.UploadObjectRequest]) (*connect.Response[storage.UploadObjectResponse], error)

Types

type Handler

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

func New

func New(p storageParams) *Handler

func (*Handler) Build

func (h *Handler) Build(opts ...connect.HandlerOption) (string, http.Handler)

func (*Handler) CopyObject

func (h *Handler) CopyObject(ctx context.Context, req *connect.Request[storage.CopyObjectRequest]) (*connect.Response[storage.CopyObjectResponse], error)

func (*Handler) CreateBucket

func (h *Handler) CreateBucket(ctx context.Context, req *connect.Request[storage.CreateBucketRequest]) (*connect.Response[storage.CreateBucketResponse], error)

CreateBucket implements storageconnect.ServiceHandler

func (Handler) CreateProvider

func (h Handler) CreateProvider(ctx context.Context, req *connect.Request[storage.CreateProviderRequest]) (*connect.Response[storage.CreateProviderResponse], error)

func (*Handler) DeleteBucket

func (h *Handler) DeleteBucket(ctx context.Context, req *connect.Request[storage.DeleteBucketRequest]) (*connect.Response[storage.DeleteBucketResponse], error)

DeleteBucket implements storageconnect.ServiceHandler

func (*Handler) DeleteObject

func (h *Handler) DeleteObject(ctx context.Context, req *connect.Request[storage.DeleteObjectRequest]) (*connect.Response[storage.DeleteObjectResponse], error)

DeleteObject implements storageconnect.ServiceHandler

func (Handler) DeleteProvider

func (h Handler) DeleteProvider(ctx context.Context, req *connect.Request[storage.DeleteProviderRequest]) (*connect.Response[storage.DeleteProviderResponse], error)

func (*Handler) DownloadObject

func (h *Handler) DownloadObject(ctx context.Context, req *connect.Request[storage.DownloadObjectRequest], stream *connect.ServerStream[storage.DownloadObjectResponse]) error

DownloadObject implements storageconnect.ServiceHandler

func (*Handler) GetBucket

func (h *Handler) GetBucket(ctx context.Context, req *connect.Request[storage.GetBucketRequest]) (*connect.Response[storage.GetBucketResponse], error)

GetBucket implements storageconnect.ServiceHandler

func (*Handler) GetObject

func (h *Handler) GetObject(ctx context.Context, req *connect.Request[storage.GetObjectRequest]) (*connect.Response[storage.GetObjectResponse], error)

GetObject implements storageconnect.ServiceHandler

func (Handler) GetProvider

func (h Handler) GetProvider(ctx context.Context, req *connect.Request[storage.GetProviderRequest]) (*connect.Response[storage.GetProviderResponse], error)

func (*Handler) ListBuckets

func (h *Handler) ListBuckets(ctx context.Context, req *connect.Request[storage.ListBucketsRequest]) (*connect.Response[storage.ListBucketsResponse], error)

ListBuckets implements storageconnect.ServiceHandler

func (*Handler) ListObjects

func (h *Handler) ListObjects(ctx context.Context, req *connect.Request[storage.ListObjectsRequest]) (*connect.Response[storage.ListObjectsResponse], error)

ListObjects implements storageconnect.ServiceHandler

func (Handler) ListProviders

func (h Handler) ListProviders(ctx context.Context, req *connect.Request[storage.ListProvidersRequest]) (*connect.Response[storage.ListProvidersResponse], error)

func (Handler) LookupProvider

func (h Handler) LookupProvider(ctx context.Context, req *connect.Request[storage.LookupProviderRequest]) (*connect.Response[storage.LookupProviderResponse], error)

func (*Handler) ServiceName

func (h *Handler) ServiceName() string

func (Handler) UnlinkBucket

func (h Handler) UnlinkBucket(ctx context.Context, req *connect.Request[storage.UnlinkBucketRequest]) (*connect.Response[storage.UnlinkBucketResponse], error)

func (*Handler) UploadObject

func (h *Handler) UploadObject(ctx context.Context, stream *connect.ClientStream[storage.UploadObjectRequest]) (*connect.Response[storage.UploadObjectResponse], error)

UploadObject implements storageconnect.ServiceHandler