definition

package
v0.0.0-...-6f318c5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 24, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source
const BufferSize = 4094
View Source
const (
	Name = "storage.v2"
)

Variables

View Source
var File_integrations_storage_v2_definition_storage_proto protoreflect.FileDescriptor
View Source
var StorageV2_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "storage.StorageV2",
	HandlerType: (*StorageV2Server)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Init",
			Handler:    _StorageV2_Init_Handler,
		},
		{
			MethodName: "HeadObject",
			Handler:    _StorageV2_HeadObject_Handler,
		},
		{
			MethodName: "DeleteObject",
			Handler:    _StorageV2_DeleteObject_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReadObject",
			Handler:       _StorageV2_ReadObject_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "WriteObject",
			Handler:       _StorageV2_WriteObject_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "ListObjects",
			Handler:       _StorageV2_ListObjects_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "integrations/storage/v2/definition/storage.proto",
}

StorageV2_ServiceDesc is the grpc.ServiceDesc for StorageV2 service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func Receive

func Receive(ctx context.Context, client StorageV2Client, key string, out io.Writer) (int, error)

func RegisterStorageV2Server

func RegisterStorageV2Server(s grpc.ServiceRegistrar, srv StorageV2Server)

Types

type StorageV2Client

type StorageV2Client interface {
	// Allows to init the Storage settings (like bucket creation)
	Init(ctx context.Context, in *StorageV2InitRequest, opts ...grpc.CallOption) (*StorageV2InitResponse, error)
	// Allows to Read Objects using stream
	ReadObject(ctx context.Context, in *StorageV2ReadObjectRequest, opts ...grpc.CallOption) (StorageV2_ReadObjectClient, error)
	// Allows to Write Objects using stream
	WriteObject(ctx context.Context, opts ...grpc.CallOption) (StorageV2_WriteObjectClient, error)
	// Gets basic info about object
	HeadObject(ctx context.Context, in *StorageV2HeadObjectRequest, opts ...grpc.CallOption) (*StorageV2HeadObjectResponse, error)
	// Deletes object
	DeleteObject(ctx context.Context, in *StorageV2DeleteObjectRequest, opts ...grpc.CallOption) (*StorageV2DeleteObjectResponse, error)
	// List all objects in batches
	ListObjects(ctx context.Context, in *StorageV2ListObjectsRequest, opts ...grpc.CallOption) (StorageV2_ListObjectsClient, error)
}

StorageV2Client is the client API for StorageV2 service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStorageV2Client

func NewStorageV2Client(cc grpc.ClientConnInterface) StorageV2Client

type StorageV2DeleteObjectRequest

type StorageV2DeleteObjectRequest struct {

	// Defines Object Path/Key
	Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 DeleteObject Request

func (*StorageV2DeleteObjectRequest) Descriptor deprecated

func (*StorageV2DeleteObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2DeleteObjectRequest.ProtoReflect.Descriptor instead.

func (*StorageV2DeleteObjectRequest) GetPath

func (*StorageV2DeleteObjectRequest) ProtoMessage

func (*StorageV2DeleteObjectRequest) ProtoMessage()

func (*StorageV2DeleteObjectRequest) ProtoReflect

func (*StorageV2DeleteObjectRequest) Reset

func (x *StorageV2DeleteObjectRequest) Reset()

func (*StorageV2DeleteObjectRequest) String

type StorageV2DeleteObjectResponse

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

StorageV2 DeleteObject Response

func (*StorageV2DeleteObjectResponse) Descriptor deprecated

func (*StorageV2DeleteObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2DeleteObjectResponse.ProtoReflect.Descriptor instead.

func (*StorageV2DeleteObjectResponse) ProtoMessage

func (*StorageV2DeleteObjectResponse) ProtoMessage()

func (*StorageV2DeleteObjectResponse) ProtoReflect

func (*StorageV2DeleteObjectResponse) Reset

func (x *StorageV2DeleteObjectResponse) Reset()

func (*StorageV2DeleteObjectResponse) String

type StorageV2HeadObjectRequest

type StorageV2HeadObjectRequest struct {

	// Defines Object Path/Key
	Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 HeadObject Request

func (*StorageV2HeadObjectRequest) Descriptor deprecated

func (*StorageV2HeadObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2HeadObjectRequest.ProtoReflect.Descriptor instead.

func (*StorageV2HeadObjectRequest) GetPath

func (*StorageV2HeadObjectRequest) ProtoMessage

func (*StorageV2HeadObjectRequest) ProtoMessage()

func (*StorageV2HeadObjectRequest) ProtoReflect

func (*StorageV2HeadObjectRequest) Reset

func (x *StorageV2HeadObjectRequest) Reset()

func (*StorageV2HeadObjectRequest) String

func (x *StorageV2HeadObjectRequest) String() string

type StorageV2HeadObjectResponse

type StorageV2HeadObjectResponse struct {

	// Defines Object Info
	Info *StorageV2ObjectInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 HeadObject Response

func (*StorageV2HeadObjectResponse) Descriptor deprecated

func (*StorageV2HeadObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2HeadObjectResponse.ProtoReflect.Descriptor instead.

func (*StorageV2HeadObjectResponse) GetInfo

func (*StorageV2HeadObjectResponse) ProtoMessage

func (*StorageV2HeadObjectResponse) ProtoMessage()

func (*StorageV2HeadObjectResponse) ProtoReflect

func (*StorageV2HeadObjectResponse) Reset

func (x *StorageV2HeadObjectResponse) Reset()

func (*StorageV2HeadObjectResponse) String

func (x *StorageV2HeadObjectResponse) String() string

type StorageV2InitRequest

type StorageV2InitRequest struct {

	// Defines if required resources should be created
	Create *bool `protobuf:"varint,1,opt,name=create,proto3,oneof" json:"create,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 Init Request

func (*StorageV2InitRequest) Descriptor deprecated

func (*StorageV2InitRequest) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2InitRequest.ProtoReflect.Descriptor instead.

func (*StorageV2InitRequest) GetCreate

func (x *StorageV2InitRequest) GetCreate() bool

func (*StorageV2InitRequest) ProtoMessage

func (*StorageV2InitRequest) ProtoMessage()

func (*StorageV2InitRequest) ProtoReflect

func (x *StorageV2InitRequest) ProtoReflect() protoreflect.Message

func (*StorageV2InitRequest) Reset

func (x *StorageV2InitRequest) Reset()

func (*StorageV2InitRequest) String

func (x *StorageV2InitRequest) String() string

type StorageV2InitResponse

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

StorageV2 Init Response

func (*StorageV2InitResponse) Descriptor deprecated

func (*StorageV2InitResponse) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2InitResponse.ProtoReflect.Descriptor instead.

func (*StorageV2InitResponse) ProtoMessage

func (*StorageV2InitResponse) ProtoMessage()

func (*StorageV2InitResponse) ProtoReflect

func (x *StorageV2InitResponse) ProtoReflect() protoreflect.Message

func (*StorageV2InitResponse) Reset

func (x *StorageV2InitResponse) Reset()

func (*StorageV2InitResponse) String

func (x *StorageV2InitResponse) String() string

type StorageV2ListObjectsRequest

type StorageV2ListObjectsRequest struct {

	// Defines Object Path/Key
	Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 ListObjects Request

func (*StorageV2ListObjectsRequest) Descriptor deprecated

func (*StorageV2ListObjectsRequest) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2ListObjectsRequest.ProtoReflect.Descriptor instead.

func (*StorageV2ListObjectsRequest) GetPath

func (*StorageV2ListObjectsRequest) ProtoMessage

func (*StorageV2ListObjectsRequest) ProtoMessage()

func (*StorageV2ListObjectsRequest) ProtoReflect

func (*StorageV2ListObjectsRequest) Reset

func (x *StorageV2ListObjectsRequest) Reset()

func (*StorageV2ListObjectsRequest) String

func (x *StorageV2ListObjectsRequest) String() string

type StorageV2ListObjectsResponse

type StorageV2ListObjectsResponse struct {

	// List of the objects
	Files []*StorageV2Object `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 ListObjects Response

func (*StorageV2ListObjectsResponse) Descriptor deprecated

func (*StorageV2ListObjectsResponse) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2ListObjectsResponse.ProtoReflect.Descriptor instead.

func (*StorageV2ListObjectsResponse) GetFiles

func (*StorageV2ListObjectsResponse) ProtoMessage

func (*StorageV2ListObjectsResponse) ProtoMessage()

func (*StorageV2ListObjectsResponse) ProtoReflect

func (*StorageV2ListObjectsResponse) Reset

func (x *StorageV2ListObjectsResponse) Reset()

func (*StorageV2ListObjectsResponse) String

type StorageV2Object

type StorageV2Object struct {

	// Defines Object Path/Key
	Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Defines Object Info
	Info *StorageV2ObjectInfo `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

Defines Object Details

func List

func List(ctx context.Context, client StorageV2Client, prefix string) ([]*StorageV2Object, error)

func (*StorageV2Object) Descriptor deprecated

func (*StorageV2Object) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2Object.ProtoReflect.Descriptor instead.

func (*StorageV2Object) GetInfo

func (x *StorageV2Object) GetInfo() *StorageV2ObjectInfo

func (*StorageV2Object) GetPath

func (x *StorageV2Object) GetPath() *StorageV2Path

func (*StorageV2Object) ProtoMessage

func (*StorageV2Object) ProtoMessage()

func (*StorageV2Object) ProtoReflect

func (x *StorageV2Object) ProtoReflect() protoreflect.Message

func (*StorageV2Object) Reset

func (x *StorageV2Object) Reset()

func (*StorageV2Object) String

func (x *StorageV2Object) String() string

type StorageV2ObjectInfo

type StorageV2ObjectInfo struct {

	// Size in bytes of the object
	Size uint64 `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	// Timestamp of last update
	LastUpdated *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=last_updated,json=lastUpdated,proto3" json:"last_updated,omitempty"`
	// contains filtered or unexported fields
}

Defines Object Info

func (*StorageV2ObjectInfo) Descriptor deprecated

func (*StorageV2ObjectInfo) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2ObjectInfo.ProtoReflect.Descriptor instead.

func (*StorageV2ObjectInfo) GetLastUpdated

func (x *StorageV2ObjectInfo) GetLastUpdated() *timestamppb.Timestamp

func (*StorageV2ObjectInfo) GetSize

func (x *StorageV2ObjectInfo) GetSize() uint64

func (*StorageV2ObjectInfo) ProtoMessage

func (*StorageV2ObjectInfo) ProtoMessage()

func (*StorageV2ObjectInfo) ProtoReflect

func (x *StorageV2ObjectInfo) ProtoReflect() protoreflect.Message

func (*StorageV2ObjectInfo) Reset

func (x *StorageV2ObjectInfo) Reset()

func (*StorageV2ObjectInfo) String

func (x *StorageV2ObjectInfo) String() string

type StorageV2Path

type StorageV2Path struct {

	// Defines Object Path/Key
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

Defines Object Path/Key

func (*StorageV2Path) Descriptor deprecated

func (*StorageV2Path) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2Path.ProtoReflect.Descriptor instead.

func (*StorageV2Path) GetPath

func (x *StorageV2Path) GetPath() string

func (*StorageV2Path) ProtoMessage

func (*StorageV2Path) ProtoMessage()

func (*StorageV2Path) ProtoReflect

func (x *StorageV2Path) ProtoReflect() protoreflect.Message

func (*StorageV2Path) Reset

func (x *StorageV2Path) Reset()

func (*StorageV2Path) String

func (x *StorageV2Path) String() string

type StorageV2ReadObjectRequest

type StorageV2ReadObjectRequest struct {

	// Defines Object Path/Key
	Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 ReadObject Request

func (*StorageV2ReadObjectRequest) Descriptor deprecated

func (*StorageV2ReadObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2ReadObjectRequest.ProtoReflect.Descriptor instead.

func (*StorageV2ReadObjectRequest) GetPath

func (*StorageV2ReadObjectRequest) ProtoMessage

func (*StorageV2ReadObjectRequest) ProtoMessage()

func (*StorageV2ReadObjectRequest) ProtoReflect

func (*StorageV2ReadObjectRequest) Reset

func (x *StorageV2ReadObjectRequest) Reset()

func (*StorageV2ReadObjectRequest) String

func (x *StorageV2ReadObjectRequest) String() string

type StorageV2ReadObjectResponse

type StorageV2ReadObjectResponse struct {

	// Bytes of the object
	Chunk []byte `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 ReadObject Response

func (*StorageV2ReadObjectResponse) Descriptor deprecated

func (*StorageV2ReadObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2ReadObjectResponse.ProtoReflect.Descriptor instead.

func (*StorageV2ReadObjectResponse) GetChunk

func (x *StorageV2ReadObjectResponse) GetChunk() []byte

func (*StorageV2ReadObjectResponse) ProtoMessage

func (*StorageV2ReadObjectResponse) ProtoMessage()

func (*StorageV2ReadObjectResponse) ProtoReflect

func (*StorageV2ReadObjectResponse) Reset

func (x *StorageV2ReadObjectResponse) Reset()

func (*StorageV2ReadObjectResponse) String

func (x *StorageV2ReadObjectResponse) String() string

type StorageV2Server

type StorageV2Server interface {
	// Allows to init the Storage settings (like bucket creation)
	Init(context.Context, *StorageV2InitRequest) (*StorageV2InitResponse, error)
	// Allows to Read Objects using stream
	ReadObject(*StorageV2ReadObjectRequest, StorageV2_ReadObjectServer) error
	// Allows to Write Objects using stream
	WriteObject(StorageV2_WriteObjectServer) error
	// Gets basic info about object
	HeadObject(context.Context, *StorageV2HeadObjectRequest) (*StorageV2HeadObjectResponse, error)
	// Deletes object
	DeleteObject(context.Context, *StorageV2DeleteObjectRequest) (*StorageV2DeleteObjectResponse, error)
	// List all objects in batches
	ListObjects(*StorageV2ListObjectsRequest, StorageV2_ListObjectsServer) error
	// contains filtered or unexported methods
}

StorageV2Server is the server API for StorageV2 service. All implementations must embed UnimplementedStorageV2Server for forward compatibility

type StorageV2WriteObjectRequest

type StorageV2WriteObjectRequest struct {

	// Defines Object Path/Key
	Path *StorageV2Path `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Bytes of the object
	Chunk []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 WriteObject Request

func (*StorageV2WriteObjectRequest) Descriptor deprecated

func (*StorageV2WriteObjectRequest) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2WriteObjectRequest.ProtoReflect.Descriptor instead.

func (*StorageV2WriteObjectRequest) GetChunk

func (x *StorageV2WriteObjectRequest) GetChunk() []byte

func (*StorageV2WriteObjectRequest) GetPath

func (*StorageV2WriteObjectRequest) ProtoMessage

func (*StorageV2WriteObjectRequest) ProtoMessage()

func (*StorageV2WriteObjectRequest) ProtoReflect

func (*StorageV2WriteObjectRequest) Reset

func (x *StorageV2WriteObjectRequest) Reset()

func (*StorageV2WriteObjectRequest) String

func (x *StorageV2WriteObjectRequest) String() string

type StorageV2WriteObjectResponse

type StorageV2WriteObjectResponse struct {

	// Bytes Saved
	Bytes int64 `protobuf:"varint,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
	// Checksum (sha256) of the object
	Checksum string `protobuf:"bytes,2,opt,name=checksum,proto3" json:"checksum,omitempty"`
	// contains filtered or unexported fields
}

StorageV2 WriteObject Response

func (*StorageV2WriteObjectResponse) Descriptor deprecated

func (*StorageV2WriteObjectResponse) Descriptor() ([]byte, []int)

Deprecated: Use StorageV2WriteObjectResponse.ProtoReflect.Descriptor instead.

func (*StorageV2WriteObjectResponse) GetBytes

func (x *StorageV2WriteObjectResponse) GetBytes() int64

func (*StorageV2WriteObjectResponse) GetChecksum

func (x *StorageV2WriteObjectResponse) GetChecksum() string

func (*StorageV2WriteObjectResponse) ProtoMessage

func (*StorageV2WriteObjectResponse) ProtoMessage()

func (*StorageV2WriteObjectResponse) ProtoReflect

func (*StorageV2WriteObjectResponse) Reset

func (x *StorageV2WriteObjectResponse) Reset()

func (*StorageV2WriteObjectResponse) String

type StorageV2_ListObjectsClient

type StorageV2_ListObjectsClient interface {
	Recv() (*StorageV2ListObjectsResponse, error)
	grpc.ClientStream
}

type StorageV2_ListObjectsServer

type StorageV2_ListObjectsServer interface {
	Send(*StorageV2ListObjectsResponse) error
	grpc.ServerStream
}

type StorageV2_ReadObjectClient

type StorageV2_ReadObjectClient interface {
	Recv() (*StorageV2ReadObjectResponse, error)
	grpc.ClientStream
}

type StorageV2_ReadObjectServer

type StorageV2_ReadObjectServer interface {
	Send(*StorageV2ReadObjectResponse) error
	grpc.ServerStream
}

type StorageV2_WriteObjectClient

type StorageV2_WriteObjectClient interface {
	Send(*StorageV2WriteObjectRequest) error
	CloseAndRecv() (*StorageV2WriteObjectResponse, error)
	grpc.ClientStream
}

type StorageV2_WriteObjectServer

type StorageV2_WriteObjectServer interface {
	SendAndClose(*StorageV2WriteObjectResponse) error
	Recv() (*StorageV2WriteObjectRequest, error)
	grpc.ServerStream
}

type UnimplementedStorageV2Server

type UnimplementedStorageV2Server struct {
}

UnimplementedStorageV2Server must be embedded to have forward compatible implementations.

func (UnimplementedStorageV2Server) Init

func (UnimplementedStorageV2Server) WriteObject

type UnsafeStorageV2Server

type UnsafeStorageV2Server interface {
	// contains filtered or unexported methods
}

UnsafeStorageV2Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageV2Server will result in compilation errors.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL