rpc

package
v0.0.0-...-0352b5b Latest Latest
Warning

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

 Go to latest Published: Nov 29, 2024 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Add 

func Add(
	cli *client.Client,
	req *tree.AddRequest,
	opts ...client.CallOption,
) (*tree.AddResponse, error)

func AddByPath 

func AddByPath(
	cli *client.Client,
	req *tree.AddByPathRequest,
	opts ...client.CallOption,
) (*tree.AddByPathResponse, error)

func AddChain 

func AddChain(
	cli *client.Client,
	req *apemanager.AddChainRequest,
	opts ...client.CallOption,
) (*apemanager.AddChainResponse, error)

func Apply 

func Apply(cli *client.Client,
	req *tree.ApplyRequest,
	opts ...client.CallOption,
) (*tree.ApplyResponse, error)

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 GetNodeByPath 

func GetNodeByPath(cli *client.Client,
	req *tree.GetNodeByPathRequest,
	opts ...client.CallOption,
) (*tree.GetNodeByPathResponse, error)

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 Healthcheck 

func Healthcheck(cli *client.Client,
	req *tree.HealthcheckRequest,
	opts ...client.CallOption,
) (*tree.HealthcheckResponse, error)

func ListChains 

func ListChains(
	cli *client.Client,
	req *apemanager.ListChainsRequest,
	opts ...client.CallOption,
) (*apemanager.ListChainsResponse, error)

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 Move 

func Move(cli *client.Client,
	req *tree.MoveRequest,
	opts ...client.CallOption,
) (*tree.MoveResponse, error)

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 

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

PutSingleObject executes ObjectService.PutSingle RPC.

func Remove 

func Remove(cli *client.Client,
	req *tree.RemoveRequest,
	opts ...client.CallOption,
) (*tree.RemoveResponse, error)

func RemoveChain 

func RemoveChain(
	cli *client.Client,
	req *apemanager.RemoveChainRequest,
	opts ...client.CallOption,
) (*apemanager.RemoveChainResponse, error)

func TreeList 

func TreeList(cli *client.Client,
	req *tree.ListRequest,
	opts ...client.CallOption,
) (*tree.ListResponse, error)

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 GetSubTreeResponseReader 

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

func GetSubTree 

func GetSubTree(cli *client.Client,
	req *tree.GetSubTreeRequest,
	opts ...client.CallOption,
) (*GetSubTreeResponseReader, error)

func (*GetSubTreeResponseReader) Read 

func (r *GetSubTreeResponseReader) Read(resp *tree.GetSubTreeResponse) 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 PatchRequestWriter 

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

PatchRequestWriter is an object.PatchRequest message streaming component.

func Patch 

func Patch(
	cli *client.Client,
	resp *object.PatchResponse,
	opts ...client.CallOption,
) (*PatchRequestWriter, error)

Patch executes ObjectService.Patch RPC.

func (*PatchRequestWriter) Close 

func (w *PatchRequestWriter) Close() error

Close closes the stream.

func (*PatchRequestWriter) Write 

func (w *PatchRequestWriter) Write(req *object.PatchRequest) error

Write writes req to the stream.

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.

type TreeServiceGetOpLogResponseReader 

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

func GetOpLog 

func GetOpLog(cli *client.Client,
	req *tree.GetOpLogRequest,
	opts ...client.CallOption,
) (*TreeServiceGetOpLogResponseReader, error)

func (*TreeServiceGetOpLogResponseReader) Read 

func (r *TreeServiceGetOpLogResponseReader) Read(resp *tree.GetOpLogResponse) 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.