rpc

package
v1.25.1-0...-2fdc35d Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2021 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AnnounceIntermediateResult

AnnounceIntermediateResult executes ReputationService.AnnounceIntermediateResult RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func AnnounceLocalTrust

func AnnounceLocalTrust(ctx context.Context, cli protoclient.Client, prm AnnounceLocalTrustPrm, res *AnnounceLocalTrustRes) error

AnnounceLocalTrust executes ReputationService.NetworkInfo RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func AnnounceUsedSpace

func AnnounceUsedSpace(ctx context.Context, cli protoclient.Client, prm AnnounceUsedSpacePrm, res *AnnounceUsedSpaceRes) error

AnnounceUsedSpace executes ContainerService.AnnounceUsedSpace RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func Balance

func Balance(ctx context.Context, cli protoclient.Client, prm BalancePrm, res *BalanceRes) error

Balance executes AccountingService.Balance RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func CreateSession

func CreateSession(ctx context.Context, cli protoclient.Client, prm CreateSessionPrm, res *CreateSessionRes) error

CreateSession executes SessionService.Create RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func DeleteContainer

func DeleteContainer(ctx context.Context, cli protoclient.Client, prm DeleteContainerPrm, res *DeleteContainerRes) error

DeleteContainer executes ContainerService.Delete RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func DeleteObject

func DeleteObject(ctx context.Context, cli protoclient.Client, prm DeleteObjectPrm, res *DeleteObjectRes) error

DeleteObject executes ObjectService.Delete RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func GetContainer

func GetContainer(ctx context.Context, cli protoclient.Client, prm GetContainerPrm, res *GetContainerRes) error

GetContainer executes ContainerService.Get RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func GetEACL

func GetEACL(ctx context.Context, cli protoclient.Client, prm GetEACLPrm, res *GetEACLRes) error

GetEACL executes ContainerService.GetExtendedACL RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func GetObject

func GetObject(ctx context.Context, cli protoclient.Client, prm GetObjectPrm, res *GetObjectRes) error

GetObject executes ObjectService.Get RPC.

Client connection should be established.

If there is no error, server stream is available in res.Stream().

Context and res must not be nil.

func GetObjectRange

func GetObjectRange(ctx context.Context, cli protoclient.Client, prm GetObjectRangePrm, res *GetObjectRangeRes) error

GetObjectRange executes ObjectService.GetRange RPC.

Client connection should be established.

If there is no error, server stream is available in res.Stream().

Context and res must not be nil.

func HashObjectRange

func HashObjectRange(ctx context.Context, cli protoclient.Client, prm HashObjectRangePrm, res *HashObjectRangeRes) error

HashObjectRange executes ObjectService.GetRangeHash RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func HeadObject

func HeadObject(ctx context.Context, cli protoclient.Client, prm HeadObjectPrm, res *HeadObjectRes) error

HeadObject executes ObjectService.Head RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func ListContainers

func ListContainers(ctx context.Context, cli protoclient.Client, prm ListContainerPrm, res *ListContainerRes) error

ListContainer executes ContainerService.List RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func LocalNodeInfo

func LocalNodeInfo(ctx context.Context, cli protoclient.Client, prm LocalNodeInfoPrm, res *LocalNodeInfoRes) error

LocalNodeInfo executes NetmapService.LocalNodeInfo RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func NetworkInfo

func NetworkInfo(ctx context.Context, cli protoclient.Client, prm NetworkInfoPrm, res *NetworkInfoRes) error

NetworkInfo executes NetmapService.NetworkInfo RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func PutContainer

func PutContainer(ctx context.Context, cli protoclient.Client, prm PutContainerPrm, res *PutContainerRes) error

PutContainer executes ContainerService.Put RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

func PutObject

func PutObject(ctx context.Context, cli protoclient.Client, _ PutObjectPrm, res *PutObjectRes) error

PutObject executes ObjectService.Put RPC.

Client connection should be established.

If there is no error, client can stream messages using res.Stream(). When all messages are sent, stream should be closed via CloseSend. After the stream is closed w/o an error, stream.Response() contains the server response.

Context and res must not be nil.

func SearchObjects

func SearchObjects(ctx context.Context, cli protoclient.Client, prm SearchObjectsPrm, res *SearchObjectsRes) error

SearchObjects executes ObjectService.Search RPC.

Client connection should be established.

If there is no error, server stream is available in res.Stream().

Context and res must not be nil.

func SetEACL

func SetEACL(ctx context.Context, cli protoclient.Client, prm SetEACLPrm, res *SetEACLRes) error

SetEACL executes ContainerService.SetExtendedACL RPC.

Client connection should be established.

If there is no error, res.Response() contains the server response.

Context and res must not be nil.

Types

type AnnounceIntermediateResultPrm

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

AnnounceIntermediateResultPrm groups the parameters of AnnounceIntermediateResult call.

func (*AnnounceIntermediateResultPrm) SetRequest

SetRequest sets request to send to the server.

Required parameter.

type AnnounceIntermediateResultRes

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

AnnounceIntermediateResultRes groups the results of AnnounceIntermediateResult call.

func (*AnnounceIntermediateResultRes) Response

Response returns the server response.

type AnnounceLocalTrustPrm

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

AnnounceLocalTrustPrm groups the parameters of AnnounceLocalTrust call.

func (*AnnounceLocalTrustPrm) SetRequest

SetRequest sets request to send to the server.

Required parameter.

type AnnounceLocalTrustRes

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

AnnounceLocalTrustRes groups the results of AnnounceLocalTrust call.

func (*AnnounceLocalTrustRes) Response

Response returns the server response.

type AnnounceUsedSpacePrm

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

AnnounceUsedSpacePrm groups the parameters of AnnounceUsedSpace call.

func (*AnnounceUsedSpacePrm) SetRequest

SetRequest sets request to send to the server.

Required parameter.

type AnnounceUsedSpaceRes

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

AnnounceUsedSpaceRes groups the results of AnnounceUsedSpace call.

func (*AnnounceUsedSpaceRes) Response

Response returns the server response.

type BalancePrm

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

BalancePrm groups the parameters of Balance call.

func (*BalancePrm) SetRequest

func (x *BalancePrm) SetRequest(req accounting.BalanceRequest)

SetRequest sets request to send to the server.

Required parameter.

type BalanceRes

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

BalanceRes groups the results of Balance call.

func (*BalanceRes) Response

func (x *BalanceRes) Response() accounting.BalanceResponse

Response returns the server response.

type CreateSessionPrm

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

CreateSessionPrm groups the parameters of CreateSession call.

func (*CreateSessionPrm) SetRequest

func (x *CreateSessionPrm) SetRequest(req session.CreateRequest)

SetRequest sets request to send to the server.

Required parameter.

type CreateSessionRes

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

CreateSessionRes groups the results of CreateSession call.

func (*CreateSessionRes) Response

func (x *CreateSessionRes) Response() session.CreateResponse

Response returns the server response.

type DeleteContainerPrm

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

DeleteContainerPrm groups the parameters of DeleteContainer call.

func (*DeleteContainerPrm) SetRequest

func (x *DeleteContainerPrm) SetRequest(req container.DeleteRequest)

SetRequest sets request to send to the server.

Required parameter.

type DeleteContainerRes

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

DeleteContainerRes groups the results of DeleteContainer call.

func (*DeleteContainerRes) Response

Response returns the server response.

type DeleteObjectPrm

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

DeleteObjectPrm groups the parameters of DeleteObjectRange call.

func (*DeleteObjectPrm) SetRequest

func (x *DeleteObjectPrm) SetRequest(req object.DeleteRequest)

SetRequest sets request to send to the server.

Required parameter.

type DeleteObjectRes

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

DeleteObjectRes groups the results of DeleteObject call.

func (*DeleteObjectRes) Response

func (x *DeleteObjectRes) Response() object.DeleteResponse

Response returns the server response.

type GetContainerPrm

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

GetContainerPrm groups the parameters of GetContainer call.

func (*GetContainerPrm) SetRequest

func (x *GetContainerPrm) SetRequest(req container.GetRequest)

SetRequest sets request to send to the server.

Required parameter.

type GetContainerRes

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

GetContainerRes groups the results of GetContainer call.

func (*GetContainerRes) Response

func (x *GetContainerRes) Response() container.GetResponse

Response returns the server response.

type GetEACLPrm

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

GetEACLPrm groups the parameters of GetEACL call.

func (*GetEACLPrm) SetRequest

func (x *GetEACLPrm) SetRequest(req container.GetExtendedACLRequest)

SetRequest sets request to send to the server.

Required parameter.

type GetEACLRes

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

GetEACLRes groups the results of GetEACL call.

func (*GetEACLRes) Response

Response returns the server response.

type GetObjectPrm

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

GetObjectPrm groups the parameters of GetObject call.

func (*GetObjectPrm) SetRequest

func (x *GetObjectPrm) SetRequest(req object.GetRequest)

SetRequest sets request to send to the server.

Required parameter.

type GetObjectRangePrm

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

GetObjectRangePrm groups the parameters of GetObjectRange call.

func (*GetObjectRangePrm) SetRequest

func (x *GetObjectRangePrm) SetRequest(req object.GetRangeRequest)

SetRequest sets request to send to the server.

Required parameter.

type GetObjectRangeRes

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

GetObjectRangeRes groups the results of GetObjectRange call.

func (GetObjectRangeRes) Stream

Stream returns server stream as GetObjectRangeStream.

type GetObjectRangeStream

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

GetObjectRangeStream a wrapper over client.MessageReaderCloser which provides method to read object.GetRangeResponse messages.

func (*GetObjectRangeStream) Read

Read reads next stream message into the object.GetRangeResponse.

Returns io.EOF of streaming is finished.

type GetObjectRes

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

GetObjectRes groups the results of GetObject call.

func (GetObjectRes) Stream

func (x GetObjectRes) Stream() GetObjectStream

m returns server stream as GetObjectStream.

type GetObjectStream

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

GetObjectStream a wrapper over client.MessageReaderCloser which provides method to read object.GetResponse messages.

func (*GetObjectStream) Read

func (x *GetObjectStream) Read(resp *object.GetResponse) error

Read reads next stream message into the object.GetResponse.

Returns io.EOF of streaming is finished.

type HashObjectRangePrm

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

HashObjectRangePrm groups the parameters of HashObjectRange call.

func (*HashObjectRangePrm) SetRequest

func (x *HashObjectRangePrm) SetRequest(req object.GetRangeHashRequest)

SetRequest sets request to send to the server.

Required parameter.

type HashObjectRangeRes

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

HashObjectRangeRes groups the results of HashObjectRange call.

func (*HashObjectRangeRes) Response

Response returns the server response.

type HeadObjectPrm

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

HeadObjectPrm groups the parameters of HeadObject call.

func (*HeadObjectPrm) SetRequest

func (x *HeadObjectPrm) SetRequest(req object.HeadRequest)

SetRequest sets request to send to the server.

Required parameter.

type HeadObjectRes

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

HeadObjectRes groups the results of HeadObject call.

func (*HeadObjectRes) Response

func (x *HeadObjectRes) Response() object.HeadResponse

Response returns the server response.

type ListContainerPrm

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

ListContainerPrm groups the parameters of ListContainers call.

func (*ListContainerPrm) SetRequest

func (x *ListContainerPrm) SetRequest(req container.ListRequest)

SetRequest sets request to send to the server.

Required parameter.

type ListContainerRes

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

ListContainerRes groups the results of ListContainers call.

func (*ListContainerRes) Response

func (x *ListContainerRes) Response() container.ListResponse

Response returns the server response.

type LocalNodeInfoPrm

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

LocalNodeInfoPrm groups the parameters of LocalNodeInfo call.

func (*LocalNodeInfoPrm) SetRequest

func (x *LocalNodeInfoPrm) SetRequest(req netmap.LocalNodeInfoRequest)

SetRequest sets request to send to the server.

Required parameter.

type LocalNodeInfoRes

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

LocalNodeInfoRes groups the results of LocalNodeInfo call.

func (*LocalNodeInfoRes) Response

Response returns the server response.

type NetworkInfoPrm

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

NetworkInfoPrm groups the parameters of NetworkInfo call.

func (*NetworkInfoPrm) SetRequest

func (x *NetworkInfoPrm) SetRequest(req netmap.NetworkInfoRequest)

SetRequest sets request to send to the server.

Required parameter.

type NetworkInfoRes

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

NetworkInfoRes groups the results of NetworkInfo call.

func (*NetworkInfoRes) Response

Response returns the server response.

type PutContainerPrm

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

PutContainerPrm groups the parameters of PutContainer call.

func (*PutContainerPrm) SetRequest

func (x *PutContainerPrm) SetRequest(req container.PutRequest)

SetRequest sets request to send to the server.

Required parameter.

type PutContainerRes

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

PutContainerRes groups the results of PutContainer call.

func (*PutContainerRes) Response

func (x *PutContainerRes) Response() container.PutResponse

Response returns the server response.

type PutObjectPrm

type PutObjectPrm struct{}

GetObjectPrm groups the parameters of PutObject call.

type PutObjectRes

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

PutObjectRes groups the results of PutObject call.

func (PutObjectRes) Stream

func (x PutObjectRes) Stream() PutObjectStream

Response returns client stream as PutObjectStream.

type PutObjectStream

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

PutObjectStream is a wrapper over client.MessageWriterCloser which provides method to write object.PutRequest messages.

func (PutObjectStream) CloseSend

func (x PutObjectStream) CloseSend() error

CloseSend calls CloseSend on underlying MessageWriterCloser.

All Write calls should be done before CloseSend.

func (PutObjectStream) Response

func (x PutObjectStream) Response() object.PutResponse

Response returns the server response. Should be called after the successful CloseSend.

func (PutObjectStream) Write

func (x PutObjectStream) Write(req object.PutRequest) error

Write writes object.GetResponse into the stream.

Write should not be called after CloseSend.

type SearchObjectsPrm

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

SearchObjectsPrm groups the parameters of SearchObjects call.

func (*SearchObjectsPrm) SetRequest

func (x *SearchObjectsPrm) SetRequest(req object.SearchRequest)

SetRequest sets request to send to the server.

Required parameter.

type SearchObjectsRes

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

SearchObjectsRes groups the results of SearchObjects call.

func (SearchObjectsRes) Stream

Stream returns server stream as SearchObjectsStream.

type SearchObjectsStream

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

SearchObjectsStream a wrapper over client.MessageReaderCloser which provides method to read object.SearchResponse messages.

func (*SearchObjectsStream) Read

Read reads next stream message into the object.SearchResponse.

Returns io.EOF of streaming is finished.

type SetEACLPrm

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

SetEACLPrm groups the parameters of SetEACL call.

func (*SetEACLPrm) SetRequest

func (x *SetEACLPrm) SetRequest(req container.SetExtendedACLRequest)

SetRequest sets request to send to the server.

Required parameter.

type SetEACLRes

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

SetEACLRes groups the results of SetEACL call.

func (*SetEACLRes) Response

Response returns the server response.

Jump to

Keyboard shortcuts

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