pb

package
v0.0.0-...-12a4b7c Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2025 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	IPCNodeAPI_ConnectionParams_FullMethodName        = "/ipcnodeapi.IPCNodeAPI/ConnectionParams"
	IPCNodeAPI_BucketCreate_FullMethodName            = "/ipcnodeapi.IPCNodeAPI/BucketCreate"
	IPCNodeAPI_BucketView_FullMethodName              = "/ipcnodeapi.IPCNodeAPI/BucketView"
	IPCNodeAPI_BucketList_FullMethodName              = "/ipcnodeapi.IPCNodeAPI/BucketList"
	IPCNodeAPI_BucketDelete_FullMethodName            = "/ipcnodeapi.IPCNodeAPI/BucketDelete"
	IPCNodeAPI_FileUploadChunkCreate_FullMethodName   = "/ipcnodeapi.IPCNodeAPI/FileUploadChunkCreate"
	IPCNodeAPI_FileUploadBlock_FullMethodName         = "/ipcnodeapi.IPCNodeAPI/FileUploadBlock"
	IPCNodeAPI_FileView_FullMethodName                = "/ipcnodeapi.IPCNodeAPI/FileView"
	IPCNodeAPI_FileDownloadCreate_FullMethodName      = "/ipcnodeapi.IPCNodeAPI/FileDownloadCreate"
	IPCNodeAPI_FileDownloadChunkCreate_FullMethodName = "/ipcnodeapi.IPCNodeAPI/FileDownloadChunkCreate"
	IPCNodeAPI_FileDownloadBlock_FullMethodName       = "/ipcnodeapi.IPCNodeAPI/FileDownloadBlock"
	IPCNodeAPI_FileList_FullMethodName                = "/ipcnodeapi.IPCNodeAPI/FileList"
	IPCNodeAPI_FileDelete_FullMethodName              = "/ipcnodeapi.IPCNodeAPI/FileDelete"
)
View Source 
const (
	NodeAPI_BucketCreate_FullMethodName = "/nodeapi.NodeAPI/BucketCreate"
	NodeAPI_BucketView_FullMethodName   = "/nodeapi.NodeAPI/BucketView"
	NodeAPI_BucketList_FullMethodName   = "/nodeapi.NodeAPI/BucketList"
	NodeAPI_BucketDelete_FullMethodName = "/nodeapi.NodeAPI/BucketDelete"
)
View Source 
const (
	StreamAPI_FileUploadCreate_FullMethodName          = "/nodeapi.StreamAPI/FileUploadCreate"
	StreamAPI_FileUploadChunkCreate_FullMethodName     = "/nodeapi.StreamAPI/FileUploadChunkCreate"
	StreamAPI_FileUploadBlock_FullMethodName           = "/nodeapi.StreamAPI/FileUploadBlock"
	StreamAPI_FileUploadCommit_FullMethodName          = "/nodeapi.StreamAPI/FileUploadCommit"
	StreamAPI_FileDownloadCreate_FullMethodName        = "/nodeapi.StreamAPI/FileDownloadCreate"
	StreamAPI_FileDownloadRangeCreate_FullMethodName   = "/nodeapi.StreamAPI/FileDownloadRangeCreate"
	StreamAPI_FileDownloadChunkCreate_FullMethodName   = "/nodeapi.StreamAPI/FileDownloadChunkCreate"
	StreamAPI_FileDownloadChunkCreateV2_FullMethodName = "/nodeapi.StreamAPI/FileDownloadChunkCreateV2"
	StreamAPI_FileDownloadBlock_FullMethodName         = "/nodeapi.StreamAPI/FileDownloadBlock"
	StreamAPI_FileList_FullMethodName                  = "/nodeapi.StreamAPI/FileList"
	StreamAPI_FileView_FullMethodName                  = "/nodeapi.StreamAPI/FileView"
	StreamAPI_FileVersions_FullMethodName              = "/nodeapi.StreamAPI/FileVersions"
	StreamAPI_FileDelete_FullMethodName                = "/nodeapi.StreamAPI/FileDelete"
)

Variables

View Source 
var File_ipcnodeapi_proto protoreflect.FileDescriptor
View Source 
var File_nodeapi_proto protoreflect.FileDescriptor
View Source 
var IPCNodeAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ipcnodeapi.IPCNodeAPI",
	HandlerType: (*IPCNodeAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConnectionParams",
			Handler:    _IPCNodeAPI_ConnectionParams_Handler,
		},
		{
			MethodName: "BucketCreate",
			Handler:    _IPCNodeAPI_BucketCreate_Handler,
		},
		{
			MethodName: "BucketView",
			Handler:    _IPCNodeAPI_BucketView_Handler,
		},
		{
			MethodName: "BucketList",
			Handler:    _IPCNodeAPI_BucketList_Handler,
		},
		{
			MethodName: "BucketDelete",
			Handler:    _IPCNodeAPI_BucketDelete_Handler,
		},
		{
			MethodName: "FileUploadChunkCreate",
			Handler:    _IPCNodeAPI_FileUploadChunkCreate_Handler,
		},
		{
			MethodName: "FileView",
			Handler:    _IPCNodeAPI_FileView_Handler,
		},
		{
			MethodName: "FileDownloadCreate",
			Handler:    _IPCNodeAPI_FileDownloadCreate_Handler,
		},
		{
			MethodName: "FileDownloadChunkCreate",
			Handler:    _IPCNodeAPI_FileDownloadChunkCreate_Handler,
		},
		{
			MethodName: "FileList",
			Handler:    _IPCNodeAPI_FileList_Handler,
		},
		{
			MethodName: "FileDelete",
			Handler:    _IPCNodeAPI_FileDelete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FileUploadBlock",
			Handler:       _IPCNodeAPI_FileUploadBlock_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "FileDownloadBlock",
			Handler:       _IPCNodeAPI_FileDownloadBlock_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "ipcnodeapi.proto",
}

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

View Source 
var NodeAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodeapi.NodeAPI",
	HandlerType: (*NodeAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "BucketCreate",
			Handler:    _NodeAPI_BucketCreate_Handler,
		},
		{
			MethodName: "BucketView",
			Handler:    _NodeAPI_BucketView_Handler,
		},
		{
			MethodName: "BucketList",
			Handler:    _NodeAPI_BucketList_Handler,
		},
		{
			MethodName: "BucketDelete",
			Handler:    _NodeAPI_BucketDelete_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "nodeapi.proto",
}

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

View Source 
var StreamAPI_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "nodeapi.StreamAPI",
	HandlerType: (*StreamAPIServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FileUploadCreate",
			Handler:    _StreamAPI_FileUploadCreate_Handler,
		},
		{
			MethodName: "FileUploadChunkCreate",
			Handler:    _StreamAPI_FileUploadChunkCreate_Handler,
		},
		{
			MethodName: "FileUploadCommit",
			Handler:    _StreamAPI_FileUploadCommit_Handler,
		},
		{
			MethodName: "FileDownloadCreate",
			Handler:    _StreamAPI_FileDownloadCreate_Handler,
		},
		{
			MethodName: "FileDownloadRangeCreate",
			Handler:    _StreamAPI_FileDownloadRangeCreate_Handler,
		},
		{
			MethodName: "FileDownloadChunkCreate",
			Handler:    _StreamAPI_FileDownloadChunkCreate_Handler,
		},
		{
			MethodName: "FileDownloadChunkCreateV2",
			Handler:    _StreamAPI_FileDownloadChunkCreateV2_Handler,
		},
		{
			MethodName: "FileList",
			Handler:    _StreamAPI_FileList_Handler,
		},
		{
			MethodName: "FileView",
			Handler:    _StreamAPI_FileView_Handler,
		},
		{
			MethodName: "FileVersions",
			Handler:    _StreamAPI_FileVersions_Handler,
		},
		{
			MethodName: "FileDelete",
			Handler:    _StreamAPI_FileDelete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "FileUploadBlock",
			Handler:       _StreamAPI_FileUploadBlock_Handler,
			ClientStreams: true,
		},
		{
			StreamName:    "FileDownloadBlock",
			Handler:       _StreamAPI_FileDownloadBlock_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "nodeapi.proto",
}

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

Functions

func RegisterIPCNodeAPIServer 

func RegisterIPCNodeAPIServer(s grpc.ServiceRegistrar, srv IPCNodeAPIServer)

func RegisterNodeAPIServer 

func RegisterNodeAPIServer(s grpc.ServiceRegistrar, srv NodeAPIServer)

func RegisterStreamAPIServer 

func RegisterStreamAPIServer(s grpc.ServiceRegistrar, srv StreamAPIServer)

Types

type BucketCreateRequest 

type BucketCreateRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketCreateRequest) Descriptor deprecated 

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

Deprecated: Use BucketCreateRequest.ProtoReflect.Descriptor instead.

func (*BucketCreateRequest) GetName 

func (x *BucketCreateRequest) GetName() string

func (*BucketCreateRequest) ProtoMessage 

func (*BucketCreateRequest) ProtoMessage()

func (*BucketCreateRequest) ProtoReflect 

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

func (*BucketCreateRequest) Reset 

func (x *BucketCreateRequest) Reset()

func (*BucketCreateRequest) String 

func (x *BucketCreateRequest) String() string

type BucketCreateResponse 

type BucketCreateResponse struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketCreateResponse) Descriptor deprecated 

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

Deprecated: Use BucketCreateResponse.ProtoReflect.Descriptor instead.

func (*BucketCreateResponse) GetCreatedAt 

func (x *BucketCreateResponse) GetCreatedAt() *timestamppb.Timestamp

func (*BucketCreateResponse) GetName 

func (x *BucketCreateResponse) GetName() string

func (*BucketCreateResponse) ProtoMessage 

func (*BucketCreateResponse) ProtoMessage()

func (*BucketCreateResponse) ProtoReflect 

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

func (*BucketCreateResponse) Reset 

func (x *BucketCreateResponse) Reset()

func (*BucketCreateResponse) String 

func (x *BucketCreateResponse) String() string

type BucketDeleteRequest 

type BucketDeleteRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketDeleteRequest) Descriptor deprecated 

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

Deprecated: Use BucketDeleteRequest.ProtoReflect.Descriptor instead.

func (*BucketDeleteRequest) GetName 

func (x *BucketDeleteRequest) GetName() string

func (*BucketDeleteRequest) ProtoMessage 

func (*BucketDeleteRequest) ProtoMessage()

func (*BucketDeleteRequest) ProtoReflect 

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

func (*BucketDeleteRequest) Reset 

func (x *BucketDeleteRequest) Reset()

func (*BucketDeleteRequest) String 

func (x *BucketDeleteRequest) String() string

type BucketDeleteResponse 

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

func (*BucketDeleteResponse) Descriptor deprecated 

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

Deprecated: Use BucketDeleteResponse.ProtoReflect.Descriptor instead.

func (*BucketDeleteResponse) ProtoMessage 

func (*BucketDeleteResponse) ProtoMessage()

func (*BucketDeleteResponse) ProtoReflect 

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

func (*BucketDeleteResponse) Reset 

func (x *BucketDeleteResponse) Reset()

func (*BucketDeleteResponse) String 

func (x *BucketDeleteResponse) String() string

type BucketListRequest 

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

func (*BucketListRequest) Descriptor deprecated 

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

Deprecated: Use BucketListRequest.ProtoReflect.Descriptor instead.

func (*BucketListRequest) ProtoMessage 

func (*BucketListRequest) ProtoMessage()

func (*BucketListRequest) ProtoReflect 

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

func (*BucketListRequest) Reset 

func (x *BucketListRequest) Reset()

func (*BucketListRequest) String 

func (x *BucketListRequest) String() string

type BucketListResponse 

type BucketListResponse struct {
	Buckets []*BucketListResponse_Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketListResponse) Descriptor deprecated 

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

Deprecated: Use BucketListResponse.ProtoReflect.Descriptor instead.

func (*BucketListResponse) GetBuckets 

func (x *BucketListResponse) GetBuckets() []*BucketListResponse_Bucket

func (*BucketListResponse) ProtoMessage 

func (*BucketListResponse) ProtoMessage()

func (*BucketListResponse) ProtoReflect 

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

func (*BucketListResponse) Reset 

func (x *BucketListResponse) Reset()

func (*BucketListResponse) String 

func (x *BucketListResponse) String() string

type BucketListResponse_Bucket 

type BucketListResponse_Bucket struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketListResponse_Bucket) Descriptor deprecated 

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

Deprecated: Use BucketListResponse_Bucket.ProtoReflect.Descriptor instead.

func (*BucketListResponse_Bucket) GetCreatedAt 

func (x *BucketListResponse_Bucket) GetCreatedAt() *timestamppb.Timestamp

func (*BucketListResponse_Bucket) GetName 

func (x *BucketListResponse_Bucket) GetName() string

func (*BucketListResponse_Bucket) ProtoMessage 

func (*BucketListResponse_Bucket) ProtoMessage()

func (*BucketListResponse_Bucket) ProtoReflect 

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

func (*BucketListResponse_Bucket) Reset 

func (x *BucketListResponse_Bucket) Reset()

func (*BucketListResponse_Bucket) String 

func (x *BucketListResponse_Bucket) String() string

type BucketViewRequest 

type BucketViewRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketViewRequest) Descriptor deprecated 

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

Deprecated: Use BucketViewRequest.ProtoReflect.Descriptor instead.

func (*BucketViewRequest) GetBucketName 

func (x *BucketViewRequest) GetBucketName() string

func (*BucketViewRequest) ProtoMessage 

func (*BucketViewRequest) ProtoMessage()

func (*BucketViewRequest) ProtoReflect 

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

func (*BucketViewRequest) Reset 

func (x *BucketViewRequest) Reset()

func (*BucketViewRequest) String 

func (x *BucketViewRequest) String() string

type BucketViewResponse 

type BucketViewResponse struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*BucketViewResponse) Descriptor deprecated 

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

Deprecated: Use BucketViewResponse.ProtoReflect.Descriptor instead.

func (*BucketViewResponse) GetCreatedAt 

func (x *BucketViewResponse) GetCreatedAt() *timestamppb.Timestamp

func (*BucketViewResponse) GetName 

func (x *BucketViewResponse) GetName() string

func (*BucketViewResponse) ProtoMessage 

func (*BucketViewResponse) ProtoMessage()

func (*BucketViewResponse) ProtoReflect 

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

func (*BucketViewResponse) Reset 

func (x *BucketViewResponse) Reset()

func (*BucketViewResponse) String 

func (x *BucketViewResponse) String() string

type Chunk 

type Chunk struct {
	StreamId string         `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Cid      string         `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
	Index    int64          `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	Size     int64          `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Blocks   []*Chunk_Block `protobuf:"bytes,5,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk) Descriptor deprecated 

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetBlocks 

func (x *Chunk) GetBlocks() []*Chunk_Block

func (*Chunk) GetCid 

func (x *Chunk) GetCid() string

func (*Chunk) GetIndex 

func (x *Chunk) GetIndex() int64

func (*Chunk) GetSize 

func (x *Chunk) GetSize() int64

func (*Chunk) GetStreamId 

func (x *Chunk) GetStreamId() string

func (*Chunk) ProtoMessage 

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect 

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

func (*Chunk) Reset 

func (x *Chunk) Reset()

func (*Chunk) String 

func (x *Chunk) String() string

type Chunk_Block 

type Chunk_Block struct {
	Cid  string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Size int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*Chunk_Block) Descriptor deprecated 

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

Deprecated: Use Chunk_Block.ProtoReflect.Descriptor instead.

func (*Chunk_Block) GetCid 

func (x *Chunk_Block) GetCid() string

func (*Chunk_Block) GetSize 

func (x *Chunk_Block) GetSize() int64

func (*Chunk_Block) ProtoMessage 

func (*Chunk_Block) ProtoMessage()

func (*Chunk_Block) ProtoReflect 

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

func (*Chunk_Block) Reset 

func (x *Chunk_Block) Reset()

func (*Chunk_Block) String 

func (x *Chunk_Block) String() string

type ConnectionParamsRequest 

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

func (*ConnectionParamsRequest) Descriptor deprecated 

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

Deprecated: Use ConnectionParamsRequest.ProtoReflect.Descriptor instead.

func (*ConnectionParamsRequest) ProtoMessage 

func (*ConnectionParamsRequest) ProtoMessage()

func (*ConnectionParamsRequest) ProtoReflect 

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

func (*ConnectionParamsRequest) Reset 

func (x *ConnectionParamsRequest) Reset()

func (*ConnectionParamsRequest) String 

func (x *ConnectionParamsRequest) String() string

type ConnectionParamsResponse 

type ConnectionParamsResponse struct {
	DialUri         string `protobuf:"bytes,1,opt,name=dial_uri,json=dialUri,proto3" json:"dial_uri,omitempty"`
	ContractAddress string `protobuf:"bytes,2,opt,name=contract_address,json=contractAddress,proto3" json:"contract_address,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionParamsResponse) Descriptor deprecated 

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

Deprecated: Use ConnectionParamsResponse.ProtoReflect.Descriptor instead.

func (*ConnectionParamsResponse) GetContractAddress 

func (x *ConnectionParamsResponse) GetContractAddress() string

func (*ConnectionParamsResponse) GetDialUri 

func (x *ConnectionParamsResponse) GetDialUri() string

func (*ConnectionParamsResponse) ProtoMessage 

func (*ConnectionParamsResponse) ProtoMessage()

func (*ConnectionParamsResponse) ProtoReflect 

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

func (*ConnectionParamsResponse) Reset 

func (x *ConnectionParamsResponse) Reset()

func (*ConnectionParamsResponse) String 

func (x *ConnectionParamsResponse) String() string

type File 

type File struct {
	StreamId    string                 `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	RootCid     string                 `protobuf:"bytes,2,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	Name        string                 `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	EncodedSize int64                  `protobuf:"varint,4,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	Size        int64                  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	CommitedAt  *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=commited_at,json=commitedAt,proto3" json:"commited_at,omitempty"`
	// contains filtered or unexported fields
}

func (*File) Descriptor deprecated 

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

Deprecated: Use File.ProtoReflect.Descriptor instead.

func (*File) GetCommitedAt 

func (x *File) GetCommitedAt() *timestamppb.Timestamp

func (*File) GetCreatedAt 

func (x *File) GetCreatedAt() *timestamppb.Timestamp

func (*File) GetEncodedSize 

func (x *File) GetEncodedSize() int64

func (*File) GetName 

func (x *File) GetName() string

func (*File) GetRootCid 

func (x *File) GetRootCid() string

func (*File) GetSize 

func (x *File) GetSize() int64

func (*File) GetStreamId 

func (x *File) GetStreamId() string

func (*File) ProtoMessage 

func (*File) ProtoMessage()

func (*File) ProtoReflect 

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

func (*File) Reset 

func (x *File) Reset()

func (*File) String 

func (x *File) String() string

type FileBlockData 

type FileBlockData struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Cid  string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`
	// contains filtered or unexported fields
}

func (*FileBlockData) Descriptor deprecated 

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

Deprecated: Use FileBlockData.ProtoReflect.Descriptor instead.

func (*FileBlockData) GetCid 

func (x *FileBlockData) GetCid() string

func (*FileBlockData) GetData 

func (x *FileBlockData) GetData() []byte

func (*FileBlockData) ProtoMessage 

func (*FileBlockData) ProtoMessage()

func (*FileBlockData) ProtoReflect 

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

func (*FileBlockData) Reset 

func (x *FileBlockData) Reset()

func (*FileBlockData) String 

func (x *FileBlockData) String() string

type IPCBucketCreateRequest 

type IPCBucketCreateRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketCreateRequest) Descriptor deprecated 

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

Deprecated: Use IPCBucketCreateRequest.ProtoReflect.Descriptor instead.

func (*IPCBucketCreateRequest) GetName 

func (x *IPCBucketCreateRequest) GetName() string

func (*IPCBucketCreateRequest) ProtoMessage 

func (*IPCBucketCreateRequest) ProtoMessage()

func (*IPCBucketCreateRequest) ProtoReflect 

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

func (*IPCBucketCreateRequest) Reset 

func (x *IPCBucketCreateRequest) Reset()

func (*IPCBucketCreateRequest) String 

func (x *IPCBucketCreateRequest) String() string

type IPCBucketCreateResponse 

type IPCBucketCreateResponse struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketCreateResponse) Descriptor deprecated 

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

Deprecated: Use IPCBucketCreateResponse.ProtoReflect.Descriptor instead.

func (*IPCBucketCreateResponse) GetCreatedAt 

func (x *IPCBucketCreateResponse) GetCreatedAt() *timestamppb.Timestamp

func (*IPCBucketCreateResponse) GetName 

func (x *IPCBucketCreateResponse) GetName() string

func (*IPCBucketCreateResponse) ProtoMessage 

func (*IPCBucketCreateResponse) ProtoMessage()

func (*IPCBucketCreateResponse) ProtoReflect 

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

func (*IPCBucketCreateResponse) Reset 

func (x *IPCBucketCreateResponse) Reset()

func (*IPCBucketCreateResponse) String 

func (x *IPCBucketCreateResponse) String() string

type IPCBucketDeleteRequest 

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

func (*IPCBucketDeleteRequest) Descriptor deprecated 

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

Deprecated: Use IPCBucketDeleteRequest.ProtoReflect.Descriptor instead.

func (*IPCBucketDeleteRequest) ProtoMessage 

func (*IPCBucketDeleteRequest) ProtoMessage()

func (*IPCBucketDeleteRequest) ProtoReflect 

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

func (*IPCBucketDeleteRequest) Reset 

func (x *IPCBucketDeleteRequest) Reset()

func (*IPCBucketDeleteRequest) String 

func (x *IPCBucketDeleteRequest) String() string

type IPCBucketDeleteResponse 

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

func (*IPCBucketDeleteResponse) Descriptor deprecated 

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

Deprecated: Use IPCBucketDeleteResponse.ProtoReflect.Descriptor instead.

func (*IPCBucketDeleteResponse) ProtoMessage 

func (*IPCBucketDeleteResponse) ProtoMessage()

func (*IPCBucketDeleteResponse) ProtoReflect 

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

func (*IPCBucketDeleteResponse) Reset 

func (x *IPCBucketDeleteResponse) Reset()

func (*IPCBucketDeleteResponse) String 

func (x *IPCBucketDeleteResponse) String() string

type IPCBucketListRequest 

type IPCBucketListRequest struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketListRequest) Descriptor deprecated 

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

Deprecated: Use IPCBucketListRequest.ProtoReflect.Descriptor instead.

func (*IPCBucketListRequest) GetAddress 

func (x *IPCBucketListRequest) GetAddress() string

func (*IPCBucketListRequest) ProtoMessage 

func (*IPCBucketListRequest) ProtoMessage()

func (*IPCBucketListRequest) ProtoReflect 

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

func (*IPCBucketListRequest) Reset 

func (x *IPCBucketListRequest) Reset()

func (*IPCBucketListRequest) String 

func (x *IPCBucketListRequest) String() string

type IPCBucketListResponse 

type IPCBucketListResponse struct {
	Buckets []*IPCBucketListResponse_IPCBucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketListResponse) Descriptor deprecated 

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

Deprecated: Use IPCBucketListResponse.ProtoReflect.Descriptor instead.

func (*IPCBucketListResponse) GetBuckets 

func (x *IPCBucketListResponse) GetBuckets() []*IPCBucketListResponse_IPCBucket

func (*IPCBucketListResponse) ProtoMessage 

func (*IPCBucketListResponse) ProtoMessage()

func (*IPCBucketListResponse) ProtoReflect 

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

func (*IPCBucketListResponse) Reset 

func (x *IPCBucketListResponse) Reset()

func (*IPCBucketListResponse) String 

func (x *IPCBucketListResponse) String() string

type IPCBucketListResponse_IPCBucket 

type IPCBucketListResponse_IPCBucket struct {
	Name      string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketListResponse_IPCBucket) Descriptor deprecated 

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

Deprecated: Use IPCBucketListResponse_IPCBucket.ProtoReflect.Descriptor instead.

func (*IPCBucketListResponse_IPCBucket) GetCreatedAt 

func (x *IPCBucketListResponse_IPCBucket) GetCreatedAt() *timestamppb.Timestamp

func (*IPCBucketListResponse_IPCBucket) GetName 

func (x *IPCBucketListResponse_IPCBucket) GetName() string

func (*IPCBucketListResponse_IPCBucket) ProtoMessage 

func (*IPCBucketListResponse_IPCBucket) ProtoMessage()

func (*IPCBucketListResponse_IPCBucket) ProtoReflect 

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

func (*IPCBucketListResponse_IPCBucket) Reset 

func (x *IPCBucketListResponse_IPCBucket) Reset()

func (*IPCBucketListResponse_IPCBucket) String 

func (x *IPCBucketListResponse_IPCBucket) String() string

type IPCBucketViewRequest 

type IPCBucketViewRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketViewRequest) Descriptor deprecated 

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

Deprecated: Use IPCBucketViewRequest.ProtoReflect.Descriptor instead.

func (*IPCBucketViewRequest) GetAddress 

func (x *IPCBucketViewRequest) GetAddress() string

func (*IPCBucketViewRequest) GetName 

func (x *IPCBucketViewRequest) GetName() string

func (*IPCBucketViewRequest) ProtoMessage 

func (*IPCBucketViewRequest) ProtoMessage()

func (*IPCBucketViewRequest) ProtoReflect 

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

func (*IPCBucketViewRequest) Reset 

func (x *IPCBucketViewRequest) Reset()

func (*IPCBucketViewRequest) String 

func (x *IPCBucketViewRequest) String() string

type IPCBucketViewResponse 

type IPCBucketViewResponse struct {
	Id        string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // todo: remove this when contract removes id from deleteBucket endpoint
	Name      string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCBucketViewResponse) Descriptor deprecated 

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

Deprecated: Use IPCBucketViewResponse.ProtoReflect.Descriptor instead.

func (*IPCBucketViewResponse) GetCreatedAt 

func (x *IPCBucketViewResponse) GetCreatedAt() *timestamppb.Timestamp

func (*IPCBucketViewResponse) GetId 

func (x *IPCBucketViewResponse) GetId() string

func (*IPCBucketViewResponse) GetName 

func (x *IPCBucketViewResponse) GetName() string

func (*IPCBucketViewResponse) ProtoMessage 

func (*IPCBucketViewResponse) ProtoMessage()

func (*IPCBucketViewResponse) ProtoReflect 

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

func (*IPCBucketViewResponse) Reset 

func (x *IPCBucketViewResponse) Reset()

func (*IPCBucketViewResponse) String 

func (x *IPCBucketViewResponse) String() string

type IPCChunk 

type IPCChunk struct {
	Cid    string            `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Index  int64             `protobuf:"varint,2,opt,name=index,proto3" json:"index,omitempty"`
	Size   int64             `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Blocks []*IPCChunk_Block `protobuf:"bytes,4,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCChunk) Descriptor deprecated 

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

Deprecated: Use IPCChunk.ProtoReflect.Descriptor instead.

func (*IPCChunk) GetBlocks 

func (x *IPCChunk) GetBlocks() []*IPCChunk_Block

func (*IPCChunk) GetCid 

func (x *IPCChunk) GetCid() string

func (*IPCChunk) GetIndex 

func (x *IPCChunk) GetIndex() int64

func (*IPCChunk) GetSize 

func (x *IPCChunk) GetSize() int64

func (*IPCChunk) ProtoMessage 

func (*IPCChunk) ProtoMessage()

func (*IPCChunk) ProtoReflect 

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

func (*IPCChunk) Reset 

func (x *IPCChunk) Reset()

func (*IPCChunk) String 

func (x *IPCChunk) String() string

type IPCChunk_Block 

type IPCChunk_Block struct {
	Cid  string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Size int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCChunk_Block) Descriptor deprecated 

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

Deprecated: Use IPCChunk_Block.ProtoReflect.Descriptor instead.

func (*IPCChunk_Block) GetCid 

func (x *IPCChunk_Block) GetCid() string

func (*IPCChunk_Block) GetSize 

func (x *IPCChunk_Block) GetSize() int64

func (*IPCChunk_Block) ProtoMessage 

func (*IPCChunk_Block) ProtoMessage()

func (*IPCChunk_Block) ProtoReflect 

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

func (*IPCChunk_Block) Reset 

func (x *IPCChunk_Block) Reset()

func (*IPCChunk_Block) String 

func (x *IPCChunk_Block) String() string

type IPCFileBlockData 

type IPCFileBlockData struct {
	Data     []byte    `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Cid      string    `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`      // only present in first msg of request stream
	Index    int64     `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` // only present in first msg of request stream
	Chunk    *IPCChunk `protobuf:"bytes,4,opt,name=chunk,proto3" json:"chunk,omitempty"`  // only present in first msg of request stream
	BucketId []byte    `protobuf:"bytes,5,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	FileName string    `protobuf:"bytes,6,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileBlockData) Descriptor deprecated 

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

Deprecated: Use IPCFileBlockData.ProtoReflect.Descriptor instead.

func (*IPCFileBlockData) GetBucketId 

func (x *IPCFileBlockData) GetBucketId() []byte

func (*IPCFileBlockData) GetChunk 

func (x *IPCFileBlockData) GetChunk() *IPCChunk

func (*IPCFileBlockData) GetCid 

func (x *IPCFileBlockData) GetCid() string

func (*IPCFileBlockData) GetData 

func (x *IPCFileBlockData) GetData() []byte

func (*IPCFileBlockData) GetFileName 

func (x *IPCFileBlockData) GetFileName() string

func (*IPCFileBlockData) GetIndex 

func (x *IPCFileBlockData) GetIndex() int64

func (*IPCFileBlockData) ProtoMessage 

func (*IPCFileBlockData) ProtoMessage()

func (*IPCFileBlockData) ProtoReflect 

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

func (*IPCFileBlockData) Reset 

func (x *IPCFileBlockData) Reset()

func (*IPCFileBlockData) String 

func (x *IPCFileBlockData) String() string

type IPCFileBlockDataRequest 

type IPCFileBlockDataRequest struct {
	Transaction [][]byte `protobuf:"bytes,1,rep,name=transaction,proto3" json:"transaction,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileBlockDataRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileBlockDataRequest.ProtoReflect.Descriptor instead.

func (*IPCFileBlockDataRequest) GetTransaction 

func (x *IPCFileBlockDataRequest) GetTransaction() [][]byte

func (*IPCFileBlockDataRequest) ProtoMessage 

func (*IPCFileBlockDataRequest) ProtoMessage()

func (*IPCFileBlockDataRequest) ProtoReflect 

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

func (*IPCFileBlockDataRequest) Reset 

func (x *IPCFileBlockDataRequest) Reset()

func (*IPCFileBlockDataRequest) String 

func (x *IPCFileBlockDataRequest) String() string

type IPCFileDeleteRequest 

type IPCFileDeleteRequest struct {
	Transaction []byte `protobuf:"bytes,1,opt,name=transaction,proto3" json:"transaction,omitempty"`
	BucketName  []byte `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	Name        string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDeleteRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileDeleteRequest.ProtoReflect.Descriptor instead.

func (*IPCFileDeleteRequest) GetBucketName 

func (x *IPCFileDeleteRequest) GetBucketName() []byte

func (*IPCFileDeleteRequest) GetName 

func (x *IPCFileDeleteRequest) GetName() string

func (*IPCFileDeleteRequest) GetTransaction 

func (x *IPCFileDeleteRequest) GetTransaction() []byte

func (*IPCFileDeleteRequest) ProtoMessage 

func (*IPCFileDeleteRequest) ProtoMessage()

func (*IPCFileDeleteRequest) ProtoReflect 

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

func (*IPCFileDeleteRequest) Reset 

func (x *IPCFileDeleteRequest) Reset()

func (*IPCFileDeleteRequest) String 

func (x *IPCFileDeleteRequest) String() string

type IPCFileDeleteResponse 

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

func (*IPCFileDeleteResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileDeleteResponse.ProtoReflect.Descriptor instead.

func (*IPCFileDeleteResponse) ProtoMessage 

func (*IPCFileDeleteResponse) ProtoMessage()

func (*IPCFileDeleteResponse) ProtoReflect 

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

func (*IPCFileDeleteResponse) Reset 

func (x *IPCFileDeleteResponse) Reset()

func (*IPCFileDeleteResponse) String 

func (x *IPCFileDeleteResponse) String() string

type IPCFileDownloadBlockRequest 

type IPCFileDownloadBlockRequest struct {
	ChunkCid   string `protobuf:"bytes,1,opt,name=chunk_cid,json=chunkCid,proto3" json:"chunk_cid,omitempty"`
	ChunkIndex int64  `protobuf:"varint,2,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	BlockCid   string `protobuf:"bytes,3,opt,name=block_cid,json=blockCid,proto3" json:"block_cid,omitempty"`
	BlockIndex int64  `protobuf:"varint,4,opt,name=block_index,json=blockIndex,proto3" json:"block_index,omitempty"`
	BucketName string `protobuf:"bytes,5,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,6,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Address    string `protobuf:"bytes,7,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadBlockRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadBlockRequest.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadBlockRequest) GetAddress 

func (x *IPCFileDownloadBlockRequest) GetAddress() string

func (*IPCFileDownloadBlockRequest) GetBlockCid 

func (x *IPCFileDownloadBlockRequest) GetBlockCid() string

func (*IPCFileDownloadBlockRequest) GetBlockIndex 

func (x *IPCFileDownloadBlockRequest) GetBlockIndex() int64

func (*IPCFileDownloadBlockRequest) GetBucketName 

func (x *IPCFileDownloadBlockRequest) GetBucketName() string

func (*IPCFileDownloadBlockRequest) GetChunkCid 

func (x *IPCFileDownloadBlockRequest) GetChunkCid() string

func (*IPCFileDownloadBlockRequest) GetChunkIndex 

func (x *IPCFileDownloadBlockRequest) GetChunkIndex() int64

func (*IPCFileDownloadBlockRequest) GetFileName 

func (x *IPCFileDownloadBlockRequest) GetFileName() string

func (*IPCFileDownloadBlockRequest) ProtoMessage 

func (*IPCFileDownloadBlockRequest) ProtoMessage()

func (*IPCFileDownloadBlockRequest) ProtoReflect 

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

func (*IPCFileDownloadBlockRequest) Reset 

func (x *IPCFileDownloadBlockRequest) Reset()

func (*IPCFileDownloadBlockRequest) String 

func (x *IPCFileDownloadBlockRequest) String() string

type IPCFileDownloadChunkCreateRequest 

type IPCFileDownloadChunkCreateRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	ChunkCid   string `protobuf:"bytes,3,opt,name=chunk_cid,json=chunkCid,proto3" json:"chunk_cid,omitempty"`
	Address    string `protobuf:"bytes,4,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadChunkCreateRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadChunkCreateRequest.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadChunkCreateRequest) GetAddress 

func (x *IPCFileDownloadChunkCreateRequest) GetAddress() string

func (*IPCFileDownloadChunkCreateRequest) GetBucketName 

func (x *IPCFileDownloadChunkCreateRequest) GetBucketName() string

func (*IPCFileDownloadChunkCreateRequest) GetChunkCid 

func (x *IPCFileDownloadChunkCreateRequest) GetChunkCid() string

func (*IPCFileDownloadChunkCreateRequest) GetFileName 

func (x *IPCFileDownloadChunkCreateRequest) GetFileName() string

func (*IPCFileDownloadChunkCreateRequest) ProtoMessage 

func (*IPCFileDownloadChunkCreateRequest) ProtoMessage()

func (*IPCFileDownloadChunkCreateRequest) ProtoReflect 

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

func (*IPCFileDownloadChunkCreateRequest) Reset 

func (x *IPCFileDownloadChunkCreateRequest) Reset()

func (*IPCFileDownloadChunkCreateRequest) String 

func (x *IPCFileDownloadChunkCreateRequest) String() string

type IPCFileDownloadChunkCreateResponse 

type IPCFileDownloadChunkCreateResponse struct {
	Blocks []*IPCFileDownloadChunkCreateResponse_BlockDownload `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadChunkCreateResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadChunkCreateResponse.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadChunkCreateResponse) GetBlocks 

func (x *IPCFileDownloadChunkCreateResponse) GetBlocks() []*IPCFileDownloadChunkCreateResponse_BlockDownload

func (*IPCFileDownloadChunkCreateResponse) ProtoMessage 

func (*IPCFileDownloadChunkCreateResponse) ProtoMessage()

func (*IPCFileDownloadChunkCreateResponse) ProtoReflect 

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

func (*IPCFileDownloadChunkCreateResponse) Reset 

func (x *IPCFileDownloadChunkCreateResponse) Reset()

func (*IPCFileDownloadChunkCreateResponse) String 

func (x *IPCFileDownloadChunkCreateResponse) String() string

type IPCFileDownloadChunkCreateResponse_BlockDownload 

type IPCFileDownloadChunkCreateResponse_BlockDownload struct {
	Cid         string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Size        int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	NodeId      string `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Permit      string `protobuf:"bytes,5,opt,name=permit,proto3" json:"permit,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadChunkCreateResponse_BlockDownload.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) GetCid 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) GetCid() string

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) GetNodeAddress 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) GetNodeAddress() string

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) GetNodeId 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) GetNodeId() string

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) GetPermit 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) GetPermit() string

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) GetSize 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) GetSize() int64

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) ProtoMessage 

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) ProtoMessage()

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) ProtoReflect 

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

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) Reset 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) Reset()

func (*IPCFileDownloadChunkCreateResponse_BlockDownload) String 

func (x *IPCFileDownloadChunkCreateResponse_BlockDownload) String() string

type IPCFileDownloadCreateRequest 

type IPCFileDownloadCreateRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Address    string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadCreateRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadCreateRequest.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadCreateRequest) GetAddress 

func (x *IPCFileDownloadCreateRequest) GetAddress() string

func (*IPCFileDownloadCreateRequest) GetBucketName 

func (x *IPCFileDownloadCreateRequest) GetBucketName() string

func (*IPCFileDownloadCreateRequest) GetFileName 

func (x *IPCFileDownloadCreateRequest) GetFileName() string

func (*IPCFileDownloadCreateRequest) ProtoMessage 

func (*IPCFileDownloadCreateRequest) ProtoMessage()

func (*IPCFileDownloadCreateRequest) ProtoReflect 

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

func (*IPCFileDownloadCreateRequest) Reset 

func (x *IPCFileDownloadCreateRequest) Reset()

func (*IPCFileDownloadCreateRequest) String 

func (x *IPCFileDownloadCreateRequest) String() string

type IPCFileDownloadCreateResponse 

type IPCFileDownloadCreateResponse struct {
	BucketName string                                 `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	Chunks     []*IPCFileDownloadCreateResponse_Chunk `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadCreateResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadCreateResponse.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadCreateResponse) GetBucketName 

func (x *IPCFileDownloadCreateResponse) GetBucketName() string

func (*IPCFileDownloadCreateResponse) GetChunks 

func (x *IPCFileDownloadCreateResponse) GetChunks() []*IPCFileDownloadCreateResponse_Chunk

func (*IPCFileDownloadCreateResponse) ProtoMessage 

func (*IPCFileDownloadCreateResponse) ProtoMessage()

func (*IPCFileDownloadCreateResponse) ProtoReflect 

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

func (*IPCFileDownloadCreateResponse) Reset 

func (x *IPCFileDownloadCreateResponse) Reset()

func (*IPCFileDownloadCreateResponse) String 

func (x *IPCFileDownloadCreateResponse) String() string

type IPCFileDownloadCreateResponse_Chunk 

type IPCFileDownloadCreateResponse_Chunk struct {
	Cid         string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	EncodedSize int64  `protobuf:"varint,2,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	Size        int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileDownloadCreateResponse_Chunk) Descriptor deprecated 

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

Deprecated: Use IPCFileDownloadCreateResponse_Chunk.ProtoReflect.Descriptor instead.

func (*IPCFileDownloadCreateResponse_Chunk) GetCid 

func (x *IPCFileDownloadCreateResponse_Chunk) GetCid() string

func (*IPCFileDownloadCreateResponse_Chunk) GetEncodedSize 

func (x *IPCFileDownloadCreateResponse_Chunk) GetEncodedSize() int64

func (*IPCFileDownloadCreateResponse_Chunk) GetSize 

func (x *IPCFileDownloadCreateResponse_Chunk) GetSize() int64

func (*IPCFileDownloadCreateResponse_Chunk) ProtoMessage 

func (*IPCFileDownloadCreateResponse_Chunk) ProtoMessage()

func (*IPCFileDownloadCreateResponse_Chunk) ProtoReflect 

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

func (*IPCFileDownloadCreateResponse_Chunk) Reset 

func (x *IPCFileDownloadCreateResponse_Chunk) Reset()

func (*IPCFileDownloadCreateResponse_Chunk) String 

func (x *IPCFileDownloadCreateResponse_Chunk) String() string

type IPCFileListRequest 

type IPCFileListRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	Address    string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileListRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileListRequest.ProtoReflect.Descriptor instead.

func (*IPCFileListRequest) GetAddress 

func (x *IPCFileListRequest) GetAddress() string

func (*IPCFileListRequest) GetBucketName 

func (x *IPCFileListRequest) GetBucketName() string

func (*IPCFileListRequest) ProtoMessage 

func (*IPCFileListRequest) ProtoMessage()

func (*IPCFileListRequest) ProtoReflect 

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

func (*IPCFileListRequest) Reset 

func (x *IPCFileListRequest) Reset()

func (*IPCFileListRequest) String 

func (x *IPCFileListRequest) String() string

type IPCFileListResponse 

type IPCFileListResponse struct {
	List []*IPCFileListResponse_IPCFile `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileListResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileListResponse.ProtoReflect.Descriptor instead.

func (*IPCFileListResponse) GetList 

func (x *IPCFileListResponse) GetList() []*IPCFileListResponse_IPCFile

func (*IPCFileListResponse) ProtoMessage 

func (*IPCFileListResponse) ProtoMessage()

func (*IPCFileListResponse) ProtoReflect 

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

func (*IPCFileListResponse) Reset 

func (x *IPCFileListResponse) Reset()

func (*IPCFileListResponse) String 

func (x *IPCFileListResponse) String() string

type IPCFileListResponse_IPCFile 

type IPCFileListResponse_IPCFile struct {
	RootCid     string                 `protobuf:"bytes,1,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	EncodedSize int64                  `protobuf:"varint,3,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileListResponse_IPCFile) Descriptor deprecated 

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

Deprecated: Use IPCFileListResponse_IPCFile.ProtoReflect.Descriptor instead.

func (*IPCFileListResponse_IPCFile) GetCreatedAt 

func (x *IPCFileListResponse_IPCFile) GetCreatedAt() *timestamppb.Timestamp

func (*IPCFileListResponse_IPCFile) GetEncodedSize 

func (x *IPCFileListResponse_IPCFile) GetEncodedSize() int64

func (*IPCFileListResponse_IPCFile) GetName 

func (x *IPCFileListResponse_IPCFile) GetName() string

func (*IPCFileListResponse_IPCFile) GetRootCid 

func (x *IPCFileListResponse_IPCFile) GetRootCid() string

func (*IPCFileListResponse_IPCFile) ProtoMessage 

func (*IPCFileListResponse_IPCFile) ProtoMessage()

func (*IPCFileListResponse_IPCFile) ProtoReflect 

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

func (*IPCFileListResponse_IPCFile) Reset 

func (x *IPCFileListResponse_IPCFile) Reset()

func (*IPCFileListResponse_IPCFile) String 

func (x *IPCFileListResponse_IPCFile) String() string

type IPCFileUploadBlockResponse 

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

func (*IPCFileUploadBlockResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileUploadBlockResponse.ProtoReflect.Descriptor instead.

func (*IPCFileUploadBlockResponse) ProtoMessage 

func (*IPCFileUploadBlockResponse) ProtoMessage()

func (*IPCFileUploadBlockResponse) ProtoReflect 

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

func (*IPCFileUploadBlockResponse) Reset 

func (x *IPCFileUploadBlockResponse) Reset()

func (*IPCFileUploadBlockResponse) String 

func (x *IPCFileUploadBlockResponse) String() string

type IPCFileUploadChunkCreateRequest 

type IPCFileUploadChunkCreateRequest struct {
	Chunk    *IPCChunk `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	BucketId []byte    `protobuf:"bytes,2,opt,name=bucket_id,json=bucketId,proto3" json:"bucket_id,omitempty"`
	FileName string    `protobuf:"bytes,3,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileUploadChunkCreateRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileUploadChunkCreateRequest.ProtoReflect.Descriptor instead.

func (*IPCFileUploadChunkCreateRequest) GetBucketId 

func (x *IPCFileUploadChunkCreateRequest) GetBucketId() []byte

func (*IPCFileUploadChunkCreateRequest) GetChunk 

func (x *IPCFileUploadChunkCreateRequest) GetChunk() *IPCChunk

func (*IPCFileUploadChunkCreateRequest) GetFileName 

func (x *IPCFileUploadChunkCreateRequest) GetFileName() string

func (*IPCFileUploadChunkCreateRequest) ProtoMessage 

func (*IPCFileUploadChunkCreateRequest) ProtoMessage()

func (*IPCFileUploadChunkCreateRequest) ProtoReflect 

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

func (*IPCFileUploadChunkCreateRequest) Reset 

func (x *IPCFileUploadChunkCreateRequest) Reset()

func (*IPCFileUploadChunkCreateRequest) String 

func (x *IPCFileUploadChunkCreateRequest) String() string

type IPCFileUploadChunkCreateResponse 

type IPCFileUploadChunkCreateResponse struct {
	Blocks []*IPCFileUploadChunkCreateResponse_BlockUpload `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileUploadChunkCreateResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileUploadChunkCreateResponse.ProtoReflect.Descriptor instead.

func (*IPCFileUploadChunkCreateResponse) GetBlocks 

func (x *IPCFileUploadChunkCreateResponse) GetBlocks() []*IPCFileUploadChunkCreateResponse_BlockUpload

func (*IPCFileUploadChunkCreateResponse) ProtoMessage 

func (*IPCFileUploadChunkCreateResponse) ProtoMessage()

func (*IPCFileUploadChunkCreateResponse) ProtoReflect 

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

func (*IPCFileUploadChunkCreateResponse) Reset 

func (x *IPCFileUploadChunkCreateResponse) Reset()

func (*IPCFileUploadChunkCreateResponse) String 

func (x *IPCFileUploadChunkCreateResponse) String() string

type IPCFileUploadChunkCreateResponse_BlockUpload 

type IPCFileUploadChunkCreateResponse_BlockUpload struct {
	Cid         string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	NodeId      string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Permit      string `protobuf:"bytes,4,opt,name=permit,proto3" json:"permit,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileUploadChunkCreateResponse_BlockUpload) Descriptor deprecated 

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

Deprecated: Use IPCFileUploadChunkCreateResponse_BlockUpload.ProtoReflect.Descriptor instead.

func (*IPCFileUploadChunkCreateResponse_BlockUpload) GetCid 

func (x *IPCFileUploadChunkCreateResponse_BlockUpload) GetCid() string

func (*IPCFileUploadChunkCreateResponse_BlockUpload) GetNodeAddress 

func (x *IPCFileUploadChunkCreateResponse_BlockUpload) GetNodeAddress() string

func (*IPCFileUploadChunkCreateResponse_BlockUpload) GetNodeId 

func (x *IPCFileUploadChunkCreateResponse_BlockUpload) GetNodeId() string

func (*IPCFileUploadChunkCreateResponse_BlockUpload) GetPermit 

func (x *IPCFileUploadChunkCreateResponse_BlockUpload) GetPermit() string

func (*IPCFileUploadChunkCreateResponse_BlockUpload) ProtoMessage 

func (*IPCFileUploadChunkCreateResponse_BlockUpload) ProtoMessage()

func (*IPCFileUploadChunkCreateResponse_BlockUpload) ProtoReflect 

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

func (*IPCFileUploadChunkCreateResponse_BlockUpload) Reset 

func (x *IPCFileUploadChunkCreateResponse_BlockUpload) Reset()

func (*IPCFileUploadChunkCreateResponse_BlockUpload) String 

func (x *IPCFileUploadChunkCreateResponse_BlockUpload) String() string

type IPCFileViewRequest 

type IPCFileViewRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	Address    string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileViewRequest) Descriptor deprecated 

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

Deprecated: Use IPCFileViewRequest.ProtoReflect.Descriptor instead.

func (*IPCFileViewRequest) GetAddress 

func (x *IPCFileViewRequest) GetAddress() string

func (*IPCFileViewRequest) GetBucketName 

func (x *IPCFileViewRequest) GetBucketName() string

func (*IPCFileViewRequest) GetFileName 

func (x *IPCFileViewRequest) GetFileName() string

func (*IPCFileViewRequest) ProtoMessage 

func (*IPCFileViewRequest) ProtoMessage()

func (*IPCFileViewRequest) ProtoReflect 

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

func (*IPCFileViewRequest) Reset 

func (x *IPCFileViewRequest) Reset()

func (*IPCFileViewRequest) String 

func (x *IPCFileViewRequest) String() string

type IPCFileViewResponse 

type IPCFileViewResponse struct {
	BucketName  string                 `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName    string                 `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	RootCid     string                 `protobuf:"bytes,3,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	EncodedSize int64                  `protobuf:"varint,4,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*IPCFileViewResponse) Descriptor deprecated 

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

Deprecated: Use IPCFileViewResponse.ProtoReflect.Descriptor instead.

func (*IPCFileViewResponse) GetBucketName 

func (x *IPCFileViewResponse) GetBucketName() string

func (*IPCFileViewResponse) GetCreatedAt 

func (x *IPCFileViewResponse) GetCreatedAt() *timestamppb.Timestamp

func (*IPCFileViewResponse) GetEncodedSize 

func (x *IPCFileViewResponse) GetEncodedSize() int64

func (*IPCFileViewResponse) GetFileName 

func (x *IPCFileViewResponse) GetFileName() string

func (*IPCFileViewResponse) GetRootCid 

func (x *IPCFileViewResponse) GetRootCid() string

func (*IPCFileViewResponse) ProtoMessage 

func (*IPCFileViewResponse) ProtoMessage()

func (*IPCFileViewResponse) ProtoReflect 

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

func (*IPCFileViewResponse) Reset 

func (x *IPCFileViewResponse) Reset()

func (*IPCFileViewResponse) String 

func (x *IPCFileViewResponse) String() string

type IPCNodeAPIClient 

type IPCNodeAPIClient interface {
	ConnectionParams(ctx context.Context, in *ConnectionParamsRequest, opts ...grpc.CallOption) (*ConnectionParamsResponse, error)
	// Bucket APIs.
	BucketCreate(ctx context.Context, in *IPCBucketCreateRequest, opts ...grpc.CallOption) (*IPCBucketCreateResponse, error)
	BucketView(ctx context.Context, in *IPCBucketViewRequest, opts ...grpc.CallOption) (*IPCBucketViewResponse, error)
	BucketList(ctx context.Context, in *IPCBucketListRequest, opts ...grpc.CallOption) (*IPCBucketListResponse, error)
	BucketDelete(ctx context.Context, in *IPCBucketDeleteRequest, opts ...grpc.CallOption) (*IPCBucketDeleteResponse, error)
	// File APIs.
	FileUploadChunkCreate(ctx context.Context, in *IPCFileUploadChunkCreateRequest, opts ...grpc.CallOption) (*IPCFileUploadChunkCreateResponse, error)
	FileUploadBlock(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[IPCFileBlockData, IPCFileUploadBlockResponse], error)
	FileView(ctx context.Context, in *IPCFileViewRequest, opts ...grpc.CallOption) (*IPCFileViewResponse, error)
	FileDownloadCreate(ctx context.Context, in *IPCFileDownloadCreateRequest, opts ...grpc.CallOption) (*IPCFileDownloadCreateResponse, error)
	FileDownloadChunkCreate(ctx context.Context, in *IPCFileDownloadChunkCreateRequest, opts ...grpc.CallOption) (*IPCFileDownloadChunkCreateResponse, error)
	FileDownloadBlock(ctx context.Context, in *IPCFileDownloadBlockRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[IPCFileBlockData], error)
	FileList(ctx context.Context, in *IPCFileListRequest, opts ...grpc.CallOption) (*IPCFileListResponse, error)
	FileDelete(ctx context.Context, in *IPCFileDeleteRequest, opts ...grpc.CallOption) (*IPCFileDeleteResponse, error)
}

IPCNodeAPIClient is the client API for IPCNodeAPI 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 NewIPCNodeAPIClient 

func NewIPCNodeAPIClient(cc grpc.ClientConnInterface) IPCNodeAPIClient

type IPCNodeAPIServer 

type IPCNodeAPIServer interface {
	ConnectionParams(context.Context, *ConnectionParamsRequest) (*ConnectionParamsResponse, error)
	// Bucket APIs.
	BucketCreate(context.Context, *IPCBucketCreateRequest) (*IPCBucketCreateResponse, error)
	BucketView(context.Context, *IPCBucketViewRequest) (*IPCBucketViewResponse, error)
	BucketList(context.Context, *IPCBucketListRequest) (*IPCBucketListResponse, error)
	BucketDelete(context.Context, *IPCBucketDeleteRequest) (*IPCBucketDeleteResponse, error)
	// File APIs.
	FileUploadChunkCreate(context.Context, *IPCFileUploadChunkCreateRequest) (*IPCFileUploadChunkCreateResponse, error)
	FileUploadBlock(grpc.ClientStreamingServer[IPCFileBlockData, IPCFileUploadBlockResponse]) error
	FileView(context.Context, *IPCFileViewRequest) (*IPCFileViewResponse, error)
	FileDownloadCreate(context.Context, *IPCFileDownloadCreateRequest) (*IPCFileDownloadCreateResponse, error)
	FileDownloadChunkCreate(context.Context, *IPCFileDownloadChunkCreateRequest) (*IPCFileDownloadChunkCreateResponse, error)
	FileDownloadBlock(*IPCFileDownloadBlockRequest, grpc.ServerStreamingServer[IPCFileBlockData]) error
	FileList(context.Context, *IPCFileListRequest) (*IPCFileListResponse, error)
	FileDelete(context.Context, *IPCFileDeleteRequest) (*IPCFileDeleteResponse, error)
	// contains filtered or unexported methods
}

IPCNodeAPIServer is the server API for IPCNodeAPI service. All implementations must embed UnimplementedIPCNodeAPIServer for forward compatibility.

type IPCNodeAPI_FileDownloadBlockClient 

type IPCNodeAPI_FileDownloadBlockClient = grpc.ServerStreamingClient[IPCFileBlockData]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type IPCNodeAPI_FileDownloadBlockServer 

type IPCNodeAPI_FileDownloadBlockServer = grpc.ServerStreamingServer[IPCFileBlockData]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type IPCNodeAPI_FileUploadBlockClient 

type IPCNodeAPI_FileUploadBlockClient = grpc.ClientStreamingClient[IPCFileBlockData, IPCFileUploadBlockResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type IPCNodeAPI_FileUploadBlockServer 

type IPCNodeAPI_FileUploadBlockServer = grpc.ClientStreamingServer[IPCFileBlockData, IPCFileUploadBlockResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type NodeAPIClient 

type NodeAPIClient interface {
	// Bucket APIs.
	BucketCreate(ctx context.Context, in *BucketCreateRequest, opts ...grpc.CallOption) (*BucketCreateResponse, error)
	BucketView(ctx context.Context, in *BucketViewRequest, opts ...grpc.CallOption) (*BucketViewResponse, error)
	BucketList(ctx context.Context, in *BucketListRequest, opts ...grpc.CallOption) (*BucketListResponse, error)
	BucketDelete(ctx context.Context, in *BucketDeleteRequest, opts ...grpc.CallOption) (*BucketDeleteResponse, error)
}

NodeAPIClient is the client API for NodeAPI 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 NewNodeAPIClient 

func NewNodeAPIClient(cc grpc.ClientConnInterface) NodeAPIClient

type NodeAPIServer 

type NodeAPIServer interface {
	// Bucket APIs.
	BucketCreate(context.Context, *BucketCreateRequest) (*BucketCreateResponse, error)
	BucketView(context.Context, *BucketViewRequest) (*BucketViewResponse, error)
	BucketList(context.Context, *BucketListRequest) (*BucketListResponse, error)
	BucketDelete(context.Context, *BucketDeleteRequest) (*BucketDeleteResponse, error)
	// contains filtered or unexported methods
}

NodeAPIServer is the server API for NodeAPI service. All implementations must embed UnimplementedNodeAPIServer for forward compatibility.

type StreamAPIClient 

type StreamAPIClient interface {
	FileUploadCreate(ctx context.Context, in *StreamFileUploadCreateRequest, opts ...grpc.CallOption) (*StreamFileUploadCreateResponse, error)
	FileUploadChunkCreate(ctx context.Context, in *StreamFileUploadChunkCreateRequest, opts ...grpc.CallOption) (*StreamFileUploadChunkCreateResponse, error)
	FileUploadBlock(ctx context.Context, opts ...grpc.CallOption) (grpc.ClientStreamingClient[StreamFileBlockData, StreamFileUploadBlockResponse], error)
	FileUploadCommit(ctx context.Context, in *StreamFileUploadCommitRequest, opts ...grpc.CallOption) (*StreamFileUploadCommitResponse, error)
	FileDownloadCreate(ctx context.Context, in *StreamFileDownloadCreateRequest, opts ...grpc.CallOption) (*StreamFileDownloadCreateResponse, error)
	FileDownloadRangeCreate(ctx context.Context, in *StreamFileDownloadRangeCreateRequest, opts ...grpc.CallOption) (*StreamFileDownloadCreateResponse, error)
	FileDownloadChunkCreate(ctx context.Context, in *StreamFileDownloadChunkCreateRequest, opts ...grpc.CallOption) (*StreamFileDownloadChunkCreateResponse, error)
	FileDownloadChunkCreateV2(ctx context.Context, in *StreamFileDownloadChunkCreateRequest, opts ...grpc.CallOption) (*StreamFileDownloadChunkCreateResponseV2, error)
	FileDownloadBlock(ctx context.Context, in *StreamFileDownloadBlockRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamFileBlockData], error)
	FileList(ctx context.Context, in *StreamFileListRequest, opts ...grpc.CallOption) (*StreamFileListResponse, error)
	FileView(ctx context.Context, in *StreamFileViewRequest, opts ...grpc.CallOption) (*StreamFileViewResponse, error)
	FileVersions(ctx context.Context, in *StreamFileListVersionsRequest, opts ...grpc.CallOption) (*StreamFileListVersionsResponse, error)
	FileDelete(ctx context.Context, in *StreamFileDeleteRequest, opts ...grpc.CallOption) (*StreamFileDeleteResponse, error)
}

StreamAPIClient is the client API for StreamAPI 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.

Stream APIs.

func NewStreamAPIClient 

func NewStreamAPIClient(cc grpc.ClientConnInterface) StreamAPIClient

type StreamAPIServer 

type StreamAPIServer interface {
	FileUploadCreate(context.Context, *StreamFileUploadCreateRequest) (*StreamFileUploadCreateResponse, error)
	FileUploadChunkCreate(context.Context, *StreamFileUploadChunkCreateRequest) (*StreamFileUploadChunkCreateResponse, error)
	FileUploadBlock(grpc.ClientStreamingServer[StreamFileBlockData, StreamFileUploadBlockResponse]) error
	FileUploadCommit(context.Context, *StreamFileUploadCommitRequest) (*StreamFileUploadCommitResponse, error)
	FileDownloadCreate(context.Context, *StreamFileDownloadCreateRequest) (*StreamFileDownloadCreateResponse, error)
	FileDownloadRangeCreate(context.Context, *StreamFileDownloadRangeCreateRequest) (*StreamFileDownloadCreateResponse, error)
	FileDownloadChunkCreate(context.Context, *StreamFileDownloadChunkCreateRequest) (*StreamFileDownloadChunkCreateResponse, error)
	FileDownloadChunkCreateV2(context.Context, *StreamFileDownloadChunkCreateRequest) (*StreamFileDownloadChunkCreateResponseV2, error)
	FileDownloadBlock(*StreamFileDownloadBlockRequest, grpc.ServerStreamingServer[StreamFileBlockData]) error
	FileList(context.Context, *StreamFileListRequest) (*StreamFileListResponse, error)
	FileView(context.Context, *StreamFileViewRequest) (*StreamFileViewResponse, error)
	FileVersions(context.Context, *StreamFileListVersionsRequest) (*StreamFileListVersionsResponse, error)
	FileDelete(context.Context, *StreamFileDeleteRequest) (*StreamFileDeleteResponse, error)
	// contains filtered or unexported methods
}

StreamAPIServer is the server API for StreamAPI service. All implementations must embed UnimplementedStreamAPIServer for forward compatibility.

Stream APIs.

type StreamAPI_FileDownloadBlockClient 

type StreamAPI_FileDownloadBlockClient = grpc.ServerStreamingClient[StreamFileBlockData]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StreamAPI_FileDownloadBlockServer 

type StreamAPI_FileDownloadBlockServer = grpc.ServerStreamingServer[StreamFileBlockData]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StreamAPI_FileUploadBlockClient 

type StreamAPI_FileUploadBlockClient = grpc.ClientStreamingClient[StreamFileBlockData, StreamFileUploadBlockResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StreamAPI_FileUploadBlockServer 

type StreamAPI_FileUploadBlockServer = grpc.ClientStreamingServer[StreamFileBlockData, StreamFileUploadBlockResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StreamFileBlockData 

type StreamFileBlockData struct {
	Data  []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Cid   string `protobuf:"bytes,2,opt,name=cid,proto3" json:"cid,omitempty"`      // only present in first msg of request stream
	Index int64  `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"` // only present in first msg of request stream
	Chunk *Chunk `protobuf:"bytes,4,opt,name=chunk,proto3" json:"chunk,omitempty"`  // only present in first msg of request stream
	// contains filtered or unexported fields
}

TODO: do not reuse this message for upload and download, create seprate messages

func (*StreamFileBlockData) Descriptor deprecated 

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

Deprecated: Use StreamFileBlockData.ProtoReflect.Descriptor instead.

func (*StreamFileBlockData) GetChunk 

func (x *StreamFileBlockData) GetChunk() *Chunk

func (*StreamFileBlockData) GetCid 

func (x *StreamFileBlockData) GetCid() string

func (*StreamFileBlockData) GetData 

func (x *StreamFileBlockData) GetData() []byte

func (*StreamFileBlockData) GetIndex 

func (x *StreamFileBlockData) GetIndex() int64

func (*StreamFileBlockData) ProtoMessage 

func (*StreamFileBlockData) ProtoMessage()

func (*StreamFileBlockData) ProtoReflect 

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

func (*StreamFileBlockData) Reset 

func (x *StreamFileBlockData) Reset()

func (*StreamFileBlockData) String 

func (x *StreamFileBlockData) String() string

type StreamFileDeleteRequest 

type StreamFileDeleteRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDeleteRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileDeleteRequest.ProtoReflect.Descriptor instead.

func (*StreamFileDeleteRequest) GetBucketName 

func (x *StreamFileDeleteRequest) GetBucketName() string

func (*StreamFileDeleteRequest) GetFileName 

func (x *StreamFileDeleteRequest) GetFileName() string

func (*StreamFileDeleteRequest) ProtoMessage 

func (*StreamFileDeleteRequest) ProtoMessage()

func (*StreamFileDeleteRequest) ProtoReflect 

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

func (*StreamFileDeleteRequest) Reset 

func (x *StreamFileDeleteRequest) Reset()

func (*StreamFileDeleteRequest) String 

func (x *StreamFileDeleteRequest) String() string

type StreamFileDeleteResponse 

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

func (*StreamFileDeleteResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileDeleteResponse.ProtoReflect.Descriptor instead.

func (*StreamFileDeleteResponse) ProtoMessage 

func (*StreamFileDeleteResponse) ProtoMessage()

func (*StreamFileDeleteResponse) ProtoReflect 

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

func (*StreamFileDeleteResponse) Reset 

func (x *StreamFileDeleteResponse) Reset()

func (*StreamFileDeleteResponse) String 

func (x *StreamFileDeleteResponse) String() string

type StreamFileDownloadBlockRequest 

type StreamFileDownloadBlockRequest struct {
	StreamId   string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ChunkCid   string `protobuf:"bytes,2,opt,name=chunk_cid,json=chunkCid,proto3" json:"chunk_cid,omitempty"`
	ChunkIndex int64  `protobuf:"varint,3,opt,name=chunk_index,json=chunkIndex,proto3" json:"chunk_index,omitempty"`
	BlockCid   string `protobuf:"bytes,4,opt,name=block_cid,json=blockCid,proto3" json:"block_cid,omitempty"`
	BlockIndex int64  `protobuf:"varint,5,opt,name=block_index,json=blockIndex,proto3" json:"block_index,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadBlockRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadBlockRequest.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadBlockRequest) GetBlockCid 

func (x *StreamFileDownloadBlockRequest) GetBlockCid() string

func (*StreamFileDownloadBlockRequest) GetBlockIndex 

func (x *StreamFileDownloadBlockRequest) GetBlockIndex() int64

func (*StreamFileDownloadBlockRequest) GetChunkCid 

func (x *StreamFileDownloadBlockRequest) GetChunkCid() string

func (*StreamFileDownloadBlockRequest) GetChunkIndex 

func (x *StreamFileDownloadBlockRequest) GetChunkIndex() int64

func (*StreamFileDownloadBlockRequest) GetStreamId 

func (x *StreamFileDownloadBlockRequest) GetStreamId() string

func (*StreamFileDownloadBlockRequest) ProtoMessage 

func (*StreamFileDownloadBlockRequest) ProtoMessage()

func (*StreamFileDownloadBlockRequest) ProtoReflect 

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

func (*StreamFileDownloadBlockRequest) Reset 

func (x *StreamFileDownloadBlockRequest) Reset()

func (*StreamFileDownloadBlockRequest) String 

func (x *StreamFileDownloadBlockRequest) String() string

type StreamFileDownloadChunkCreateRequest 

type StreamFileDownloadChunkCreateRequest struct {
	StreamId string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	ChunkCid string `protobuf:"bytes,2,opt,name=chunk_cid,json=chunkCid,proto3" json:"chunk_cid,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateRequest.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateRequest) GetChunkCid 

func (x *StreamFileDownloadChunkCreateRequest) GetChunkCid() string

func (*StreamFileDownloadChunkCreateRequest) GetStreamId 

func (x *StreamFileDownloadChunkCreateRequest) GetStreamId() string

func (*StreamFileDownloadChunkCreateRequest) ProtoMessage 

func (*StreamFileDownloadChunkCreateRequest) ProtoMessage()

func (*StreamFileDownloadChunkCreateRequest) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateRequest) Reset 

func (x *StreamFileDownloadChunkCreateRequest) Reset()

func (*StreamFileDownloadChunkCreateRequest) String 

func (x *StreamFileDownloadChunkCreateRequest) String() string

type StreamFileDownloadChunkCreateResponse 

type StreamFileDownloadChunkCreateResponse struct {
	Blocks []*StreamFileDownloadChunkCreateResponse_BlockDownload `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateResponse.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateResponse) GetBlocks 

func (x *StreamFileDownloadChunkCreateResponse) GetBlocks() []*StreamFileDownloadChunkCreateResponse_BlockDownload

func (*StreamFileDownloadChunkCreateResponse) ProtoMessage 

func (*StreamFileDownloadChunkCreateResponse) ProtoMessage()

func (*StreamFileDownloadChunkCreateResponse) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateResponse) Reset 

func (x *StreamFileDownloadChunkCreateResponse) Reset()

func (*StreamFileDownloadChunkCreateResponse) String 

func (x *StreamFileDownloadChunkCreateResponse) String() string

type StreamFileDownloadChunkCreateResponseV2 

type StreamFileDownloadChunkCreateResponseV2 struct {
	Blocks []*StreamFileDownloadChunkCreateResponseV2_BlockDownload `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateResponseV2) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateResponseV2.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateResponseV2) GetBlocks 

func (x *StreamFileDownloadChunkCreateResponseV2) GetBlocks() []*StreamFileDownloadChunkCreateResponseV2_BlockDownload

func (*StreamFileDownloadChunkCreateResponseV2) ProtoMessage 

func (*StreamFileDownloadChunkCreateResponseV2) ProtoMessage()

func (*StreamFileDownloadChunkCreateResponseV2) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateResponseV2) Reset 

func (x *StreamFileDownloadChunkCreateResponseV2) Reset()

func (*StreamFileDownloadChunkCreateResponseV2) String 

func (x *StreamFileDownloadChunkCreateResponseV2) String() string

type StreamFileDownloadChunkCreateResponseV2_BlockDownload 

type StreamFileDownloadChunkCreateResponseV2_BlockDownload struct {
	Cid      string                                                          `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Size     int64                                                           `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Akave    *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave    `protobuf:"bytes,3,opt,name=akave,proto3" json:"akave,omitempty"`
	Filecoin *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin `protobuf:"bytes,4,opt,name=filecoin,proto3" json:"filecoin,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateResponseV2_BlockDownload.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetAkave 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetAkave() *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetCid 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetCid() string

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetFilecoin 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetFilecoin() *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetSize 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload) GetSize() int64

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) ProtoMessage 

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) ProtoMessage()

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) Reset 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload) Reset()

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload) String 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload) String() string

type StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave 

type StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave struct {
	NodeId      string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) GetNodeAddress 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) GetNodeAddress() string

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) GetNodeId 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) GetNodeId() string

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) ProtoMessage 

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) ProtoMessage()

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) Reset 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) Reset()

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) String 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Akave) String() string

type StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin 

type StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin struct {
	SpAddress string `protobuf:"bytes,1,opt,name=sp_address,json=spAddress,proto3" json:"sp_address,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) GetSpAddress 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) GetSpAddress() string

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) ProtoMessage 

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) ProtoMessage()

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) Reset 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) Reset()

func (*StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) String 

func (x *StreamFileDownloadChunkCreateResponseV2_BlockDownload_Filecoin) String() string

type StreamFileDownloadChunkCreateResponse_BlockDownload 

type StreamFileDownloadChunkCreateResponse_BlockDownload struct {
	Cid         string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	Size        int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	NodeAddress string `protobuf:"bytes,3,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	NodeId      string `protobuf:"bytes,4,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Permit      string `protobuf:"bytes,5,opt,name=permit,proto3" json:"permit,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadChunkCreateResponse_BlockDownload.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) GetCid 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) GetCid() string

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) GetNodeAddress 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) GetNodeAddress() string

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) GetNodeId 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) GetNodeId() string

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) GetPermit 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) GetPermit() string

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) GetSize 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) GetSize() int64

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) ProtoMessage 

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) ProtoMessage()

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) ProtoReflect 

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

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) Reset 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) Reset()

func (*StreamFileDownloadChunkCreateResponse_BlockDownload) String 

func (x *StreamFileDownloadChunkCreateResponse_BlockDownload) String() string

type StreamFileDownloadCreateRequest 

type StreamFileDownloadCreateRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	RootCid    string `protobuf:"bytes,3,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"` // optional
	// contains filtered or unexported fields
}

func (*StreamFileDownloadCreateRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadCreateRequest.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadCreateRequest) GetBucketName 

func (x *StreamFileDownloadCreateRequest) GetBucketName() string

func (*StreamFileDownloadCreateRequest) GetFileName 

func (x *StreamFileDownloadCreateRequest) GetFileName() string

func (*StreamFileDownloadCreateRequest) GetRootCid 

func (x *StreamFileDownloadCreateRequest) GetRootCid() string

func (*StreamFileDownloadCreateRequest) ProtoMessage 

func (*StreamFileDownloadCreateRequest) ProtoMessage()

func (*StreamFileDownloadCreateRequest) ProtoReflect 

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

func (*StreamFileDownloadCreateRequest) Reset 

func (x *StreamFileDownloadCreateRequest) Reset()

func (*StreamFileDownloadCreateRequest) String 

func (x *StreamFileDownloadCreateRequest) String() string

type StreamFileDownloadCreateResponse 

type StreamFileDownloadCreateResponse struct {
	BucketName string                                    `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	StreamId   string                                    `protobuf:"bytes,2,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	Chunks     []*StreamFileDownloadCreateResponse_Chunk `protobuf:"bytes,3,rep,name=chunks,proto3" json:"chunks,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadCreateResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadCreateResponse.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadCreateResponse) GetBucketName 

func (x *StreamFileDownloadCreateResponse) GetBucketName() string

func (*StreamFileDownloadCreateResponse) GetChunks 

func (x *StreamFileDownloadCreateResponse) GetChunks() []*StreamFileDownloadCreateResponse_Chunk

func (*StreamFileDownloadCreateResponse) GetStreamId 

func (x *StreamFileDownloadCreateResponse) GetStreamId() string

func (*StreamFileDownloadCreateResponse) ProtoMessage 

func (*StreamFileDownloadCreateResponse) ProtoMessage()

func (*StreamFileDownloadCreateResponse) ProtoReflect 

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

func (*StreamFileDownloadCreateResponse) Reset 

func (x *StreamFileDownloadCreateResponse) Reset()

func (*StreamFileDownloadCreateResponse) String 

func (x *StreamFileDownloadCreateResponse) String() string

type StreamFileDownloadCreateResponse_Chunk 

type StreamFileDownloadCreateResponse_Chunk struct {
	Cid         string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	EncodedSize int64  `protobuf:"varint,2,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	Size        int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadCreateResponse_Chunk) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadCreateResponse_Chunk.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadCreateResponse_Chunk) GetCid 

func (x *StreamFileDownloadCreateResponse_Chunk) GetCid() string

func (*StreamFileDownloadCreateResponse_Chunk) GetEncodedSize 

func (x *StreamFileDownloadCreateResponse_Chunk) GetEncodedSize() int64

func (*StreamFileDownloadCreateResponse_Chunk) GetSize 

func (x *StreamFileDownloadCreateResponse_Chunk) GetSize() int64

func (*StreamFileDownloadCreateResponse_Chunk) ProtoMessage 

func (*StreamFileDownloadCreateResponse_Chunk) ProtoMessage()

func (*StreamFileDownloadCreateResponse_Chunk) ProtoReflect 

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

func (*StreamFileDownloadCreateResponse_Chunk) Reset 

func (x *StreamFileDownloadCreateResponse_Chunk) Reset()

func (*StreamFileDownloadCreateResponse_Chunk) String 

func (x *StreamFileDownloadCreateResponse_Chunk) String() string

type StreamFileDownloadRangeCreateRequest 

type StreamFileDownloadRangeCreateRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	StartIndex int64  `protobuf:"varint,3,opt,name=start_index,json=startIndex,proto3" json:"start_index,omitempty"`
	EndIndex   int64  `protobuf:"varint,4,opt,name=end_index,json=endIndex,proto3" json:"end_index,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileDownloadRangeCreateRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileDownloadRangeCreateRequest.ProtoReflect.Descriptor instead.

func (*StreamFileDownloadRangeCreateRequest) GetBucketName 

func (x *StreamFileDownloadRangeCreateRequest) GetBucketName() string

func (*StreamFileDownloadRangeCreateRequest) GetEndIndex 

func (x *StreamFileDownloadRangeCreateRequest) GetEndIndex() int64

func (*StreamFileDownloadRangeCreateRequest) GetFileName 

func (x *StreamFileDownloadRangeCreateRequest) GetFileName() string

func (*StreamFileDownloadRangeCreateRequest) GetStartIndex 

func (x *StreamFileDownloadRangeCreateRequest) GetStartIndex() int64

func (*StreamFileDownloadRangeCreateRequest) ProtoMessage 

func (*StreamFileDownloadRangeCreateRequest) ProtoMessage()

func (*StreamFileDownloadRangeCreateRequest) ProtoReflect 

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

func (*StreamFileDownloadRangeCreateRequest) Reset 

func (x *StreamFileDownloadRangeCreateRequest) Reset()

func (*StreamFileDownloadRangeCreateRequest) String 

func (x *StreamFileDownloadRangeCreateRequest) String() string

type StreamFileListRequest 

type StreamFileListRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileListRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileListRequest.ProtoReflect.Descriptor instead.

func (*StreamFileListRequest) GetBucketName 

func (x *StreamFileListRequest) GetBucketName() string

func (*StreamFileListRequest) ProtoMessage 

func (*StreamFileListRequest) ProtoMessage()

func (*StreamFileListRequest) ProtoReflect 

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

func (*StreamFileListRequest) Reset 

func (x *StreamFileListRequest) Reset()

func (*StreamFileListRequest) String 

func (x *StreamFileListRequest) String() string

type StreamFileListResponse 

type StreamFileListResponse struct {
	Files []*File `protobuf:"bytes,1,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileListResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileListResponse.ProtoReflect.Descriptor instead.

func (*StreamFileListResponse) GetFiles 

func (x *StreamFileListResponse) GetFiles() []*File

func (*StreamFileListResponse) ProtoMessage 

func (*StreamFileListResponse) ProtoMessage()

func (*StreamFileListResponse) ProtoReflect 

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

func (*StreamFileListResponse) Reset 

func (x *StreamFileListResponse) Reset()

func (*StreamFileListResponse) String 

func (x *StreamFileListResponse) String() string

type StreamFileListVersionsRequest 

type StreamFileListVersionsRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileListVersionsRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileListVersionsRequest.ProtoReflect.Descriptor instead.

func (*StreamFileListVersionsRequest) GetBucketName 

func (x *StreamFileListVersionsRequest) GetBucketName() string

func (*StreamFileListVersionsRequest) GetFileName 

func (x *StreamFileListVersionsRequest) GetFileName() string

func (*StreamFileListVersionsRequest) ProtoMessage 

func (*StreamFileListVersionsRequest) ProtoMessage()

func (*StreamFileListVersionsRequest) ProtoReflect 

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

func (*StreamFileListVersionsRequest) Reset 

func (x *StreamFileListVersionsRequest) Reset()

func (*StreamFileListVersionsRequest) String 

func (x *StreamFileListVersionsRequest) String() string

type StreamFileListVersionsResponse 

type StreamFileListVersionsResponse struct {
	Versions []*File `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileListVersionsResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileListVersionsResponse.ProtoReflect.Descriptor instead.

func (*StreamFileListVersionsResponse) GetVersions 

func (x *StreamFileListVersionsResponse) GetVersions() []*File

func (*StreamFileListVersionsResponse) ProtoMessage 

func (*StreamFileListVersionsResponse) ProtoMessage()

func (*StreamFileListVersionsResponse) ProtoReflect 

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

func (*StreamFileListVersionsResponse) Reset 

func (x *StreamFileListVersionsResponse) Reset()

func (*StreamFileListVersionsResponse) String 

func (x *StreamFileListVersionsResponse) String() string

type StreamFileUploadBlockResponse 

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

func (*StreamFileUploadBlockResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadBlockResponse.ProtoReflect.Descriptor instead.

func (*StreamFileUploadBlockResponse) ProtoMessage 

func (*StreamFileUploadBlockResponse) ProtoMessage()

func (*StreamFileUploadBlockResponse) ProtoReflect 

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

func (*StreamFileUploadBlockResponse) Reset 

func (x *StreamFileUploadBlockResponse) Reset()

func (*StreamFileUploadBlockResponse) String 

func (x *StreamFileUploadBlockResponse) String() string

type StreamFileUploadChunkCreateRequest 

type StreamFileUploadChunkCreateRequest struct {
	Chunk *Chunk `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadChunkCreateRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadChunkCreateRequest.ProtoReflect.Descriptor instead.

func (*StreamFileUploadChunkCreateRequest) GetChunk 

func (x *StreamFileUploadChunkCreateRequest) GetChunk() *Chunk

func (*StreamFileUploadChunkCreateRequest) ProtoMessage 

func (*StreamFileUploadChunkCreateRequest) ProtoMessage()

func (*StreamFileUploadChunkCreateRequest) ProtoReflect 

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

func (*StreamFileUploadChunkCreateRequest) Reset 

func (x *StreamFileUploadChunkCreateRequest) Reset()

func (*StreamFileUploadChunkCreateRequest) String 

func (x *StreamFileUploadChunkCreateRequest) String() string

type StreamFileUploadChunkCreateResponse 

type StreamFileUploadChunkCreateResponse struct {
	Blocks []*StreamFileUploadChunkCreateResponse_BlockUpload `protobuf:"bytes,1,rep,name=blocks,proto3" json:"blocks,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadChunkCreateResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadChunkCreateResponse.ProtoReflect.Descriptor instead.

func (*StreamFileUploadChunkCreateResponse) GetBlocks 

func (x *StreamFileUploadChunkCreateResponse) GetBlocks() []*StreamFileUploadChunkCreateResponse_BlockUpload

func (*StreamFileUploadChunkCreateResponse) ProtoMessage 

func (*StreamFileUploadChunkCreateResponse) ProtoMessage()

func (*StreamFileUploadChunkCreateResponse) ProtoReflect 

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

func (*StreamFileUploadChunkCreateResponse) Reset 

func (x *StreamFileUploadChunkCreateResponse) Reset()

func (*StreamFileUploadChunkCreateResponse) String 

func (x *StreamFileUploadChunkCreateResponse) String() string

type StreamFileUploadChunkCreateResponse_BlockUpload 

type StreamFileUploadChunkCreateResponse_BlockUpload struct {
	Cid         string `protobuf:"bytes,1,opt,name=cid,proto3" json:"cid,omitempty"`
	NodeAddress string `protobuf:"bytes,2,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	NodeId      string `protobuf:"bytes,3,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Permit      string `protobuf:"bytes,4,opt,name=permit,proto3" json:"permit,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadChunkCreateResponse_BlockUpload) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadChunkCreateResponse_BlockUpload.ProtoReflect.Descriptor instead.

func (*StreamFileUploadChunkCreateResponse_BlockUpload) GetCid 

func (x *StreamFileUploadChunkCreateResponse_BlockUpload) GetCid() string

func (*StreamFileUploadChunkCreateResponse_BlockUpload) GetNodeAddress 

func (x *StreamFileUploadChunkCreateResponse_BlockUpload) GetNodeAddress() string

func (*StreamFileUploadChunkCreateResponse_BlockUpload) GetNodeId 

func (x *StreamFileUploadChunkCreateResponse_BlockUpload) GetNodeId() string

func (*StreamFileUploadChunkCreateResponse_BlockUpload) GetPermit 

func (x *StreamFileUploadChunkCreateResponse_BlockUpload) GetPermit() string

func (*StreamFileUploadChunkCreateResponse_BlockUpload) ProtoMessage 

func (*StreamFileUploadChunkCreateResponse_BlockUpload) ProtoMessage()

func (*StreamFileUploadChunkCreateResponse_BlockUpload) ProtoReflect 

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

func (*StreamFileUploadChunkCreateResponse_BlockUpload) Reset 

func (x *StreamFileUploadChunkCreateResponse_BlockUpload) Reset()

func (*StreamFileUploadChunkCreateResponse_BlockUpload) String 

func (x *StreamFileUploadChunkCreateResponse_BlockUpload) String() string

type StreamFileUploadCommitRequest 

type StreamFileUploadCommitRequest struct {
	StreamId   string `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	RootCid    string `protobuf:"bytes,2,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	ChunkCount int64  `protobuf:"varint,3,opt,name=chunk_count,json=chunkCount,proto3" json:"chunk_count,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadCommitRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadCommitRequest.ProtoReflect.Descriptor instead.

func (*StreamFileUploadCommitRequest) GetChunkCount 

func (x *StreamFileUploadCommitRequest) GetChunkCount() int64

func (*StreamFileUploadCommitRequest) GetRootCid 

func (x *StreamFileUploadCommitRequest) GetRootCid() string

func (*StreamFileUploadCommitRequest) GetStreamId 

func (x *StreamFileUploadCommitRequest) GetStreamId() string

func (*StreamFileUploadCommitRequest) ProtoMessage 

func (*StreamFileUploadCommitRequest) ProtoMessage()

func (*StreamFileUploadCommitRequest) ProtoReflect 

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

func (*StreamFileUploadCommitRequest) Reset 

func (x *StreamFileUploadCommitRequest) Reset()

func (*StreamFileUploadCommitRequest) String 

func (x *StreamFileUploadCommitRequest) String() string

type StreamFileUploadCommitResponse 

type StreamFileUploadCommitResponse struct {
	StreamId    string                 `protobuf:"bytes,1,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	FileName    string                 `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	BucketName  string                 `protobuf:"bytes,3,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	EncodedSize int64                  `protobuf:"varint,4,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	Size        int64                  `protobuf:"varint,5,opt,name=size,proto3" json:"size,omitempty"`
	CommittedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=committed_at,json=committedAt,proto3" json:"committed_at,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadCommitResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadCommitResponse.ProtoReflect.Descriptor instead.

func (*StreamFileUploadCommitResponse) GetBucketName 

func (x *StreamFileUploadCommitResponse) GetBucketName() string

func (*StreamFileUploadCommitResponse) GetCommittedAt 

func (x *StreamFileUploadCommitResponse) GetCommittedAt() *timestamppb.Timestamp

func (*StreamFileUploadCommitResponse) GetEncodedSize 

func (x *StreamFileUploadCommitResponse) GetEncodedSize() int64

func (*StreamFileUploadCommitResponse) GetFileName 

func (x *StreamFileUploadCommitResponse) GetFileName() string

func (*StreamFileUploadCommitResponse) GetSize 

func (x *StreamFileUploadCommitResponse) GetSize() int64

func (*StreamFileUploadCommitResponse) GetStreamId 

func (x *StreamFileUploadCommitResponse) GetStreamId() string

func (*StreamFileUploadCommitResponse) ProtoMessage 

func (*StreamFileUploadCommitResponse) ProtoMessage()

func (*StreamFileUploadCommitResponse) ProtoReflect 

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

func (*StreamFileUploadCommitResponse) Reset 

func (x *StreamFileUploadCommitResponse) Reset()

func (*StreamFileUploadCommitResponse) String 

func (x *StreamFileUploadCommitResponse) String() string

type StreamFileUploadCreateRequest 

type StreamFileUploadCreateRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadCreateRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadCreateRequest.ProtoReflect.Descriptor instead.

func (*StreamFileUploadCreateRequest) GetBucketName 

func (x *StreamFileUploadCreateRequest) GetBucketName() string

func (*StreamFileUploadCreateRequest) GetFileName 

func (x *StreamFileUploadCreateRequest) GetFileName() string

func (*StreamFileUploadCreateRequest) ProtoMessage 

func (*StreamFileUploadCreateRequest) ProtoMessage()

func (*StreamFileUploadCreateRequest) ProtoReflect 

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

func (*StreamFileUploadCreateRequest) Reset 

func (x *StreamFileUploadCreateRequest) Reset()

func (*StreamFileUploadCreateRequest) String 

func (x *StreamFileUploadCreateRequest) String() string

type StreamFileUploadCreateResponse 

type StreamFileUploadCreateResponse struct {
	BucketName string                 `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string                 `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	StreamId   string                 `protobuf:"bytes,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileUploadCreateResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileUploadCreateResponse.ProtoReflect.Descriptor instead.

func (*StreamFileUploadCreateResponse) GetBucketName 

func (x *StreamFileUploadCreateResponse) GetBucketName() string

func (*StreamFileUploadCreateResponse) GetCreatedAt 

func (x *StreamFileUploadCreateResponse) GetCreatedAt() *timestamppb.Timestamp

func (*StreamFileUploadCreateResponse) GetFileName 

func (x *StreamFileUploadCreateResponse) GetFileName() string

func (*StreamFileUploadCreateResponse) GetStreamId 

func (x *StreamFileUploadCreateResponse) GetStreamId() string

func (*StreamFileUploadCreateResponse) ProtoMessage 

func (*StreamFileUploadCreateResponse) ProtoMessage()

func (*StreamFileUploadCreateResponse) ProtoReflect 

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

func (*StreamFileUploadCreateResponse) Reset 

func (x *StreamFileUploadCreateResponse) Reset()

func (*StreamFileUploadCreateResponse) String 

func (x *StreamFileUploadCreateResponse) String() string

type StreamFileViewRequest 

type StreamFileViewRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName   string `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileViewRequest) Descriptor deprecated 

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

Deprecated: Use StreamFileViewRequest.ProtoReflect.Descriptor instead.

func (*StreamFileViewRequest) GetBucketName 

func (x *StreamFileViewRequest) GetBucketName() string

func (*StreamFileViewRequest) GetFileName 

func (x *StreamFileViewRequest) GetFileName() string

func (*StreamFileViewRequest) ProtoMessage 

func (*StreamFileViewRequest) ProtoMessage()

func (*StreamFileViewRequest) ProtoReflect 

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

func (*StreamFileViewRequest) Reset 

func (x *StreamFileViewRequest) Reset()

func (*StreamFileViewRequest) String 

func (x *StreamFileViewRequest) String() string

type StreamFileViewResponse 

type StreamFileViewResponse struct {
	BucketName  string                 `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	FileName    string                 `protobuf:"bytes,2,opt,name=file_name,json=fileName,proto3" json:"file_name,omitempty"`
	StreamId    string                 `protobuf:"bytes,3,opt,name=stream_id,json=streamId,proto3" json:"stream_id,omitempty"`
	RootCid     string                 `protobuf:"bytes,4,opt,name=root_cid,json=rootCid,proto3" json:"root_cid,omitempty"`
	EncodedSize int64                  `protobuf:"varint,5,opt,name=encoded_size,json=encodedSize,proto3" json:"encoded_size,omitempty"`
	Size        int64                  `protobuf:"varint,6,opt,name=size,proto3" json:"size,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	CommittedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=committed_at,json=committedAt,proto3" json:"committed_at,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamFileViewResponse) Descriptor deprecated 

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

Deprecated: Use StreamFileViewResponse.ProtoReflect.Descriptor instead.

func (*StreamFileViewResponse) GetBucketName 

func (x *StreamFileViewResponse) GetBucketName() string

func (*StreamFileViewResponse) GetCommittedAt 

func (x *StreamFileViewResponse) GetCommittedAt() *timestamppb.Timestamp

func (*StreamFileViewResponse) GetCreatedAt 

func (x *StreamFileViewResponse) GetCreatedAt() *timestamppb.Timestamp

func (*StreamFileViewResponse) GetEncodedSize 

func (x *StreamFileViewResponse) GetEncodedSize() int64

func (*StreamFileViewResponse) GetFileName 

func (x *StreamFileViewResponse) GetFileName() string

func (*StreamFileViewResponse) GetRootCid 

func (x *StreamFileViewResponse) GetRootCid() string

func (*StreamFileViewResponse) GetSize 

func (x *StreamFileViewResponse) GetSize() int64

func (*StreamFileViewResponse) GetStreamId 

func (x *StreamFileViewResponse) GetStreamId() string

func (*StreamFileViewResponse) ProtoMessage 

func (*StreamFileViewResponse) ProtoMessage()

func (*StreamFileViewResponse) ProtoReflect 

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

func (*StreamFileViewResponse) Reset 

func (x *StreamFileViewResponse) Reset()

func (*StreamFileViewResponse) String 

func (x *StreamFileViewResponse) String() string

type UnimplementedIPCNodeAPIServer 

type UnimplementedIPCNodeAPIServer struct{}

UnimplementedIPCNodeAPIServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedIPCNodeAPIServer) BucketCreate 

func (UnimplementedIPCNodeAPIServer) BucketCreate(context.Context, *IPCBucketCreateRequest) (*IPCBucketCreateResponse, error)

func (UnimplementedIPCNodeAPIServer) BucketDelete 

func (UnimplementedIPCNodeAPIServer) BucketDelete(context.Context, *IPCBucketDeleteRequest) (*IPCBucketDeleteResponse, error)

func (UnimplementedIPCNodeAPIServer) BucketList 

func (UnimplementedIPCNodeAPIServer) BucketList(context.Context, *IPCBucketListRequest) (*IPCBucketListResponse, error)

func (UnimplementedIPCNodeAPIServer) BucketView 

func (UnimplementedIPCNodeAPIServer) BucketView(context.Context, *IPCBucketViewRequest) (*IPCBucketViewResponse, error)

func (UnimplementedIPCNodeAPIServer) ConnectionParams 

func (UnimplementedIPCNodeAPIServer) ConnectionParams(context.Context, *ConnectionParamsRequest) (*ConnectionParamsResponse, error)

func (UnimplementedIPCNodeAPIServer) FileDelete 

func (UnimplementedIPCNodeAPIServer) FileDelete(context.Context, *IPCFileDeleteRequest) (*IPCFileDeleteResponse, error)

func (UnimplementedIPCNodeAPIServer) FileDownloadBlock 

func (UnimplementedIPCNodeAPIServer) FileDownloadBlock(*IPCFileDownloadBlockRequest, grpc.ServerStreamingServer[IPCFileBlockData]) error

func (UnimplementedIPCNodeAPIServer) FileDownloadChunkCreate 

func (UnimplementedIPCNodeAPIServer) FileDownloadChunkCreate(context.Context, *IPCFileDownloadChunkCreateRequest) (*IPCFileDownloadChunkCreateResponse, error)

func (UnimplementedIPCNodeAPIServer) FileDownloadCreate 

func (UnimplementedIPCNodeAPIServer) FileDownloadCreate(context.Context, *IPCFileDownloadCreateRequest) (*IPCFileDownloadCreateResponse, error)

func (UnimplementedIPCNodeAPIServer) FileList 

func (UnimplementedIPCNodeAPIServer) FileList(context.Context, *IPCFileListRequest) (*IPCFileListResponse, error)

func (UnimplementedIPCNodeAPIServer) FileUploadBlock 

func (UnimplementedIPCNodeAPIServer) FileUploadBlock(grpc.ClientStreamingServer[IPCFileBlockData, IPCFileUploadBlockResponse]) error

func (UnimplementedIPCNodeAPIServer) FileUploadChunkCreate 

func (UnimplementedIPCNodeAPIServer) FileUploadChunkCreate(context.Context, *IPCFileUploadChunkCreateRequest) (*IPCFileUploadChunkCreateResponse, error)

func (UnimplementedIPCNodeAPIServer) FileView 

func (UnimplementedIPCNodeAPIServer) FileView(context.Context, *IPCFileViewRequest) (*IPCFileViewResponse, error)

type UnimplementedNodeAPIServer 

type UnimplementedNodeAPIServer struct{}

UnimplementedNodeAPIServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedNodeAPIServer) BucketCreate 

func (UnimplementedNodeAPIServer) BucketCreate(context.Context, *BucketCreateRequest) (*BucketCreateResponse, error)

func (UnimplementedNodeAPIServer) BucketDelete 

func (UnimplementedNodeAPIServer) BucketDelete(context.Context, *BucketDeleteRequest) (*BucketDeleteResponse, error)

func (UnimplementedNodeAPIServer) BucketList 

func (UnimplementedNodeAPIServer) BucketList(context.Context, *BucketListRequest) (*BucketListResponse, error)

func (UnimplementedNodeAPIServer) BucketView 

func (UnimplementedNodeAPIServer) BucketView(context.Context, *BucketViewRequest) (*BucketViewResponse, error)

type UnimplementedStreamAPIServer 

type UnimplementedStreamAPIServer struct{}

UnimplementedStreamAPIServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedStreamAPIServer) FileDelete 

func (UnimplementedStreamAPIServer) FileDelete(context.Context, *StreamFileDeleteRequest) (*StreamFileDeleteResponse, error)

func (UnimplementedStreamAPIServer) FileDownloadBlock 

func (UnimplementedStreamAPIServer) FileDownloadBlock(*StreamFileDownloadBlockRequest, grpc.ServerStreamingServer[StreamFileBlockData]) error

func (UnimplementedStreamAPIServer) FileDownloadChunkCreate 

func (UnimplementedStreamAPIServer) FileDownloadChunkCreate(context.Context, *StreamFileDownloadChunkCreateRequest) (*StreamFileDownloadChunkCreateResponse, error)

func (UnimplementedStreamAPIServer) FileDownloadChunkCreateV2 

func (UnimplementedStreamAPIServer) FileDownloadChunkCreateV2(context.Context, *StreamFileDownloadChunkCreateRequest) (*StreamFileDownloadChunkCreateResponseV2, error)

func (UnimplementedStreamAPIServer) FileDownloadCreate 

func (UnimplementedStreamAPIServer) FileDownloadCreate(context.Context, *StreamFileDownloadCreateRequest) (*StreamFileDownloadCreateResponse, error)

func (UnimplementedStreamAPIServer) FileDownloadRangeCreate 

func (UnimplementedStreamAPIServer) FileDownloadRangeCreate(context.Context, *StreamFileDownloadRangeCreateRequest) (*StreamFileDownloadCreateResponse, error)

func (UnimplementedStreamAPIServer) FileList 

func (UnimplementedStreamAPIServer) FileList(context.Context, *StreamFileListRequest) (*StreamFileListResponse, error)

func (UnimplementedStreamAPIServer) FileUploadBlock 

func (UnimplementedStreamAPIServer) FileUploadBlock(grpc.ClientStreamingServer[StreamFileBlockData, StreamFileUploadBlockResponse]) error

func (UnimplementedStreamAPIServer) FileUploadChunkCreate 

func (UnimplementedStreamAPIServer) FileUploadChunkCreate(context.Context, *StreamFileUploadChunkCreateRequest) (*StreamFileUploadChunkCreateResponse, error)

func (UnimplementedStreamAPIServer) FileUploadCommit 

func (UnimplementedStreamAPIServer) FileUploadCommit(context.Context, *StreamFileUploadCommitRequest) (*StreamFileUploadCommitResponse, error)

func (UnimplementedStreamAPIServer) FileUploadCreate 

func (UnimplementedStreamAPIServer) FileUploadCreate(context.Context, *StreamFileUploadCreateRequest) (*StreamFileUploadCreateResponse, error)

func (UnimplementedStreamAPIServer) FileVersions 

func (UnimplementedStreamAPIServer) FileVersions(context.Context, *StreamFileListVersionsRequest) (*StreamFileListVersionsResponse, error)

func (UnimplementedStreamAPIServer) FileView 

func (UnimplementedStreamAPIServer) FileView(context.Context, *StreamFileViewRequest) (*StreamFileViewResponse, error)

type UnsafeIPCNodeAPIServer 

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

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

type UnsafeNodeAPIServer 

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

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

type UnsafeStreamAPIServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.