runtime

Documentation

Index

• func RegisterPlugins[T any](register plugin.Register[T], plugins map[string]plugin.Constructor[T]) error
• func Start(cmd string)
• type GrpcServer
  • func (s *GrpcServer) Delete(ctx context.Context, req *storagepb.StorageDeleteRequest) (*storagepb.StorageDeleteResponse, error)
  • func (s *GrpcServer) Exists(ctx context.Context, req *storagepb.StorageExistsRequest) (*storagepb.StorageExistsResponse, error)
  • func (s *GrpcServer) ListBlobs(ctx context.Context, req *storagepb.StorageListBlobsRequest) (*storagepb.StorageListBlobsResponse, error)
  • func (s *GrpcServer) PreSignUrl(ctx context.Context, req *storagepb.StoragePreSignUrlRequest) (*storagepb.StoragePreSignUrlResponse, error)
  • func (s *GrpcServer) Publish(ctx context.Context, req *pubsubpb.PubsubPublishRequest) (*pubsubpb.PubsubPublishResponse, error)
  • func (s *GrpcServer) Read(ctx context.Context, req *storagepb.StorageReadRequest) (*storagepb.StorageReadResponse, error)
  • func (s *GrpcServer) Write(ctx context.Context, req *storagepb.StorageWriteRequest) (*storagepb.StorageWriteResponse, error)

Functions

func RegisterPlugins

func RegisterPlugins[T any](register plugin.Register[T], plugins map[string]plugin.Constructor[T]) error

func Start

func Start(cmd string)

Types

type GrpcServer

type GrpcServer struct {
	pubsubpb.UnimplementedPubsubServer
	storagepb.UnimplementedStorageServer
}

func (*GrpcServer) Delete

func (s *GrpcServer) Delete(ctx context.Context, req *storagepb.StorageDeleteRequest) (*storagepb.StorageDeleteResponse, error)

func (*GrpcServer) Exists

func (s *GrpcServer) Exists(ctx context.Context, req *storagepb.StorageExistsRequest) (*storagepb.StorageExistsResponse, error)

func (*GrpcServer) ListBlobs

func (s *GrpcServer) ListBlobs(ctx context.Context, req *storagepb.StorageListBlobsRequest) (*storagepb.StorageListBlobsResponse, error)

func (*GrpcServer) PreSignUrl

func (s *GrpcServer) PreSignUrl(ctx context.Context, req *storagepb.StoragePreSignUrlRequest) (*storagepb.StoragePreSignUrlResponse, error)

func (*GrpcServer) Publish

func (s *GrpcServer) Publish(ctx context.Context, req *pubsubpb.PubsubPublishRequest) (*pubsubpb.PubsubPublishResponse, error)

func (*GrpcServer) Read

func (s *GrpcServer) Read(ctx context.Context, req *storagepb.StorageReadRequest) (*storagepb.StorageReadResponse, error)

func (*GrpcServer) Write

func (s *GrpcServer) Write(ctx context.Context, req *storagepb.StorageWriteRequest) (*storagepb.StorageWriteResponse, error)