rpc

package
v2.16.0 Latest Latest
Warning

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

 Go to latest Published: Sep 14, 2023 License: Apache-2.0 Imports: 8 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnnounceUsedSpace 

func AnnounceUsedSpace(
	cli *client.Client,
	req *container.AnnounceUsedSpaceRequest,
	opts ...client.CallOption,
) (*container.PutResponse, error)

AnnounceUsedSpace executes ContainerService.AnnounceUsedSpace RPC.

func Balance 

func Balance(
	cli *client.Client,
	req *accounting.BalanceRequest,
	opts ...client.CallOption,
) (*accounting.BalanceResponse, error)

Balance executes AccountingService.Balance RPC.

func CreateSession 

func CreateSession(
	cli *client.Client,
	req *session.CreateRequest,
	opts ...client.CallOption,
) (*session.CreateResponse, error)

func DeleteContainer 

func DeleteContainer(
	cli *client.Client,
	req *container.DeleteRequest,
	opts ...client.CallOption,
) (*container.PutResponse, error)

DeleteContainer executes ContainerService.Delete RPC.

func DeleteObject 

func DeleteObject(
	cli *client.Client,
	req *object.DeleteRequest,
	opts ...client.CallOption,
) (*object.DeleteResponse, error)

DeleteObject executes ObjectService.Delete RPC.

func GetContainer 

func GetContainer(
	cli *client.Client,
	req *container.GetRequest,
	opts ...client.CallOption,
) (*container.GetResponse, error)

GetContainer executes ContainerService.Get RPC.

func GetEACL 

func GetEACL(
	cli *client.Client,
	req *container.GetExtendedACLRequest,
	opts ...client.CallOption,
) (*container.GetExtendedACLResponse, error)

GetEACL executes ContainerService.GetExtendedACL RPC.

func HashObjectRange 

func HashObjectRange(
	cli *client.Client,
	req *object.GetRangeHashRequest,
	opts ...client.CallOption,
) (*object.GetRangeHashResponse, error)

HashObjectRange executes ObjectService.GetRangeHash RPC.

func HeadObject 

func HeadObject(
	cli *client.Client,
	req *object.HeadRequest,
	opts ...client.CallOption,
) (*object.HeadResponse, error)

HeadObject executes ObjectService.Head RPC.

func ListContainers 

func ListContainers(
	cli *client.Client,
	req *container.ListRequest,
	opts ...client.CallOption,
) (*container.ListResponse, error)

ListContainers executes ContainerService.List RPC.

func LocalNodeInfo 

func LocalNodeInfo(
	cli *client.Client,
	req *netmap.LocalNodeInfoRequest,
	opts ...client.CallOption,
) (*netmap.LocalNodeInfoResponse, error)

LocalNodeInfo executes NetmapService.LocalNodeInfo RPC.

func NetMapSnapshot 

func NetMapSnapshot(
	cli *client.Client,
	req *netmap.SnapshotRequest,
	opts ...client.CallOption,
) (*netmap.SnapshotResponse, error)

NetMapSnapshot executes NetmapService.NetmapSnapshot RPC.

func NetworkInfo 

func NetworkInfo(
	cli *client.Client,
	req *netmap.NetworkInfoRequest,
	opts ...client.CallOption,
) (*netmap.NetworkInfoResponse, error)

NetworkInfo executes NetmapService.NetworkInfo RPC.

func PutContainer 

func PutContainer(
	cli *client.Client,
	req *container.PutRequest,
	opts ...client.CallOption,
) (*container.PutResponse, error)

PutContainer executes ContainerService.Put RPC.

func PutSingleObject added in v2.16.0 

func PutSingleObject(
	cli *client.Client,
	req *object.PutSingleRequest,
	opts ...client.CallOption,
) (*object.PutSingleResponse, error)

PutSingleObject executes ObjectService.PutSingle RPC.

func SetEACL 

func SetEACL(
	cli *client.Client,
	req *container.SetExtendedACLRequest,
	opts ...client.CallOption,
) (*container.PutResponse, error)

SetEACL executes ContainerService.SetExtendedACL RPC.

Types

type GetResponseReader 

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

GetResponseReader is an object.GetResponse stream reader.

func GetObject 

func GetObject(
	cli *client.Client,
	req *object.GetRequest,
	opts ...client.CallOption,
) (*GetResponseReader, error)

GetObject executes ObjectService.Get RPC.

func (*GetResponseReader) Read 

func (r *GetResponseReader) Read(resp *object.GetResponse) error

Read reads response from the stream.

Returns io.EOF of streaming is finished.

type ObjectRangeResponseReader 

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

GetResponseReader is an object.GetRangeResponse stream reader.

func GetObjectRange 

func GetObjectRange(
	cli *client.Client,
	req *object.GetRangeRequest,
	opts ...client.CallOption,
) (*ObjectRangeResponseReader, error)

GetObjectRange executes ObjectService.GetRange RPC.

func (*ObjectRangeResponseReader) Read 

func (r *ObjectRangeResponseReader) Read(resp *object.GetRangeResponse) error

Read reads response from the stream.

Returns io.EOF of streaming is finished.

type PutRequestWriter 

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

PutRequestWriter is an object.PutRequest message streaming component.

func PutObject 

func PutObject(
	cli *client.Client,
	resp *object.PutResponse,
	opts ...client.CallOption,
) (*PutRequestWriter, error)

PutObject executes ObjectService.Put RPC.

func (*PutRequestWriter) Close 

func (w *PutRequestWriter) Close() error

Close closes the stream.

func (*PutRequestWriter) Write 

func (w *PutRequestWriter) Write(req *object.PutRequest) error

Write writes req to the stream.

type SearchResponseReader 

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

GetResponseReader is an object.SearchResponse stream reader.

func SearchObjects 

func SearchObjects(
	cli *client.Client,
	req *object.SearchRequest,
	opts ...client.CallOption,
) (*SearchResponseReader, error)

SearchObjects executes ObjectService.Search RPC.

func (*SearchResponseReader) Read 

func (r *SearchResponseReader) Read(resp *object.SearchResponse) error

Read reads response from the stream.

Returns io.EOF of streaming is finished.

Source Files

View all Source files

Directories

Path Synopsis
test

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.