client

Oct 19, 2021

Changes in this version

type Option

+ func WithResponseInfoHandler(f func(ResponseMetaInfo) error) Option

+ type ResponseMetaInfo struct

+ func (x ResponseMetaInfo) ResponderKey() []byte

Jun 28, 2021

Changes in this version

type GetObjectParams

+ func (p *GetObjectParams) WithPayloadReaderHandler(f ReaderHandler) *GetObjectParams

+ type ReaderHandler func(io.Reader)

Jun 3, 2021

Changes in this version

type Client

+ Conn func() io.Closer

type Option

+ func WithTLSConfig(cfg *tls.Config) Option

+ func WithURIAddress(addr string, tlsCfg *tls.Config) Option

May 7, 2021

Changes in this version

+ type AnnounceIntermediateTrustPrm struct

+ func (x *AnnounceIntermediateTrustPrm) Epoch() uint64

+ func (x *AnnounceIntermediateTrustPrm) SetEpoch(epoch uint64)

+ func (x *AnnounceIntermediateTrustPrm) SetIteration(iter uint32)

+ func (x *AnnounceIntermediateTrustPrm) SetTrust(trust *reputation.PeerToPeerTrust)

+ func (x AnnounceIntermediateTrustPrm) Iteration() uint32

+ func (x AnnounceIntermediateTrustPrm) Trust() *reputation.PeerToPeerTrust

+ type AnnounceIntermediateTrustRes struct

+ type AnnounceLocalTrustPrm struct

+ func (x *AnnounceLocalTrustPrm) SetEpoch(epoch uint64)

+ func (x *AnnounceLocalTrustPrm) SetTrusts(trusts []*reputation.Trust)

+ func (x AnnounceLocalTrustPrm) Epoch() uint64

+ func (x AnnounceLocalTrustPrm) Trusts() []*reputation.Trust

+ type AnnounceLocalTrustRes struct

+ type Reputation interface

+ AnnounceIntermediateTrust func(context.Context, AnnounceIntermediateTrustPrm, ...CallOption) (*AnnounceIntermediateTrustRes, error)

+ AnnounceLocalTrust func(context.Context, AnnounceLocalTrustPrm, ...CallOption) (*AnnounceLocalTrustRes, error)

Mar 22, 2021

Changes in this version

+ type Accounting interface

+ GetBalance func(context.Context, *owner.ID, ...CallOption) (*accounting.Decimal, error)

type CallOption

+ func WithKey(key *ecdsa.PrivateKey) CallOption

type Client

+ Raw func() *client.Client

+ type Container interface

+ AnnounceContainerUsedSpace func(context.Context, []container.UsedSpaceAnnouncement, ...CallOption) error

+ DeleteContainer func(context.Context, *container.ID, ...CallOption) error

+ GetContainer func(context.Context, *container.ID, ...CallOption) (*container.Container, error)

+ GetEACL func(context.Context, *container.ID, ...CallOption) (*EACLWithSignature, error)

+ ListContainers func(context.Context, *owner.ID, ...CallOption) ([]*container.ID, error)

+ PutContainer func(context.Context, *container.Container, ...CallOption) (*container.ID, error)

+ SetEACL func(context.Context, *eacl.Table, ...CallOption) error

+ type EndpointInfo struct

+ func (e *EndpointInfo) LatestVersion() *pkg.Version

+ func (e *EndpointInfo) NodeInfo() *netmap.NodeInfo

+ type Netmap interface

+ EndpointInfo func(context.Context, ...CallOption) (*EndpointInfo, error)

+ NetworkInfo func(context.Context, ...CallOption) (*netmap.NetworkInfo, error)

+ type Object interface

+ DeleteObject func(context.Context, *DeleteObjectParams, ...CallOption) error

+ GetObject func(context.Context, *GetObjectParams, ...CallOption) (*object.Object, error)

+ GetObjectHeader func(context.Context, *ObjectHeaderParams, ...CallOption) (*object.Object, error)

+ ObjectPayloadRangeData func(context.Context, *RangeDataParams, ...CallOption) ([]byte, error)

+ ObjectPayloadRangeSHA256 func(context.Context, *RangeChecksumParams, ...CallOption) ([][sha256.Size]byte, error)

+ ObjectPayloadRangeTZ func(context.Context, *RangeChecksumParams, ...CallOption) ([][TZSize]byte, error)

+ PutObject func(context.Context, *PutObjectParams, ...CallOption) (*object.ID, error)

+ SearchObject func(context.Context, *SearchObjectParams, ...CallOption) ([]*object.ID, error)

type Option

+ func WithDefaultPrivateKey(key *ecdsa.PrivateKey) Option

+ type Session interface

+ CreateSession func(context.Context, uint64, ...CallOption) (*token.SessionToken, error)

Feb 26, 2021

Changes in this version

type Client

+ func (c Client) NetworkInfo(ctx context.Context, opts ...CallOption) (*netmap.NetworkInfo, error)

Feb 11, 2021

Changes in this version

type Client

+ func (c Client) AnnounceContainerUsedSpace(ctx context.Context, announce []container.UsedSpaceAnnouncement, ...) error

Dec 18, 2020

Changes in this version

+ func GetVerifiedContainerStructure(ctx context.Context, c *Client, id *container.ID, opts ...CallOption) (*container.Container, error)

Dec 11, 2020

Changes in this version

+ func DeleteObject(c *Client, ctx context.Context, p *DeleteObjectParams, opts ...CallOption) (*object.Address, error)

type DeleteObjectParams

+ func (p *DeleteObjectParams) Address() *object.Address

+ func (p *DeleteObjectParams) TombstoneAddressTarget() ObjectAddressWriter

+ func (p *DeleteObjectParams) WithTombstoneAddressTarget(v ObjectAddressWriter) *DeleteObjectParams

type GetObjectParams

+ func (p *GetObjectParams) Address() *object.Address

+ func (p *GetObjectParams) PayloadWriter() io.Writer

+ func (p *GetObjectParams) RawFlag() bool

+ func (p *GetObjectParams) WithRawFlag(v bool) *GetObjectParams

+ type ObjectAddressWriter interface

+ SetAddress func(*object.Address)

type ObjectHeaderParams

+ func (p *ObjectHeaderParams) Address() *object.Address

+ func (p *ObjectHeaderParams) AllFields() bool

+ func (p *ObjectHeaderParams) RawFlag() bool

+ func (p *ObjectHeaderParams) WithRawFlag(v bool) *ObjectHeaderParams

type PutObjectParams

+ func (p *PutObjectParams) Object() *object.Object

+ func (p *PutObjectParams) PayloadReader() io.Reader

type RangeChecksumParams

+ func (p *RangeChecksumParams) Address() *object.Address

+ func (p *RangeChecksumParams) RangeList() []*object.Range

+ func (p *RangeChecksumParams) Salt() []byte

type RangeDataParams

+ func (p *RangeDataParams) Address() *object.Address

+ func (p *RangeDataParams) DataWriter() io.Writer

+ func (p *RangeDataParams) Range() *object.Range

+ func (p *RangeDataParams) Raw() bool

+ func (p *RangeDataParams) WithRaw(v bool) *RangeDataParams

type SearchObjectParams

+ func (p *SearchObjectParams) ContainerID() *container.ID

+ func (p *SearchObjectParams) SearchFilters() object.SearchFilters

Nov 25, 2020

Changes in this version

type Client

+ func (c Client) GetEACLWithSignature(ctx context.Context, id *container.ID, opts ...CallOption) (*EACLWithSignature, error)

+ type EACLWithSignature struct

+ func (e EACLWithSignature) EACL() *eacl.Table

+ func (e EACLWithSignature) Signature() *pkg.Signature

type Option

+ func WithDialTimeout(dur time.Duration) Option

Nov 17, 2020

Changes in this version

+ const TZSize

+ type CallOption interface

+ func WithBearer(token *token.BearerToken) CallOption

+ func WithEpoch(epoch uint64) CallOption

+ func WithSession(token *token.SessionToken) CallOption

+ func WithTTL(ttl uint32) CallOption

+ func WithXHeader(x *pkg.XHeader) CallOption

+ type Client struct

+ func New(key *ecdsa.PrivateKey, opts ...Option) (*Client, error)

+ func (c *Client) AttachBearerToken(token *token.BearerToken)

+ func (c *Client) AttachSessionToken(token *token.SessionToken)

+ func (c *Client) DeleteObject(ctx context.Context, p *DeleteObjectParams, opts ...CallOption) error

+ func (c *Client) GetObject(ctx context.Context, p *GetObjectParams, opts ...CallOption) (*object.Object, error)

+ func (c *Client) GetObjectHeader(ctx context.Context, p *ObjectHeaderParams, opts ...CallOption) (*object.Object, error)

+ func (c *Client) ObjectPayloadRangeData(ctx context.Context, p *RangeDataParams, opts ...CallOption) ([]byte, error)

+ func (c *Client) ObjectPayloadRangeSHA256(ctx context.Context, p *RangeChecksumParams, opts ...CallOption) ([][sha256.Size]byte, error)

+ func (c *Client) ObjectPayloadRangeTZ(ctx context.Context, p *RangeChecksumParams, opts ...CallOption) ([][TZSize]byte, error)

+ func (c *Client) PutObject(ctx context.Context, p *PutObjectParams, opts ...CallOption) (*object.ID, error)

+ func (c *Client) SearchObject(ctx context.Context, p *SearchObjectParams, opts ...CallOption) ([]*object.ID, error)

+ func (c Client) CreateSession(ctx context.Context, expiration uint64, opts ...CallOption) (*token.SessionToken, error)

+ func (c Client) DeleteContainer(ctx context.Context, id *container.ID, opts ...CallOption) error

+ func (c Client) EndpointInfo(ctx context.Context, opts ...CallOption) (*netmap.NodeInfo, error)

+ func (c Client) Epoch(ctx context.Context, opts ...CallOption) (uint64, error)

+ func (c Client) GetBalance(ctx context.Context, owner *owner.ID, opts ...CallOption) (*accounting.Decimal, error)

+ func (c Client) GetContainer(ctx context.Context, id *container.ID, opts ...CallOption) (*container.Container, error)

+ func (c Client) GetEACL(ctx context.Context, id *container.ID, opts ...CallOption) (*eacl.Table, error)

+ func (c Client) GetSelfBalance(ctx context.Context, opts ...CallOption) (*accounting.Decimal, error)

+ func (c Client) ListContainers(ctx context.Context, owner *owner.ID, opts ...CallOption) ([]*container.ID, error)

+ func (c Client) ListSelfContainers(ctx context.Context, opts ...CallOption) ([]*container.ID, error)

+ func (c Client) PutContainer(ctx context.Context, cnr *container.Container, opts ...CallOption) (*container.ID, error)

+ func (c Client) SetEACL(ctx context.Context, eacl *eacl.Table, opts ...CallOption) error

+ type DeleteObjectParams struct

+ func (p *DeleteObjectParams) WithAddress(v *object.Address) *DeleteObjectParams

+ type GetObjectParams struct

+ func (p *GetObjectParams) WithAddress(v *object.Address) *GetObjectParams

+ func (p *GetObjectParams) WithPayloadWriter(w io.Writer) *GetObjectParams

+ type ObjectHeaderParams struct

+ func (p *ObjectHeaderParams) WithAddress(v *object.Address) *ObjectHeaderParams

+ func (p *ObjectHeaderParams) WithAllFields() *ObjectHeaderParams

+ func (p *ObjectHeaderParams) WithMainFields() *ObjectHeaderParams

+ type Option interface

+ func WithAddress(addr string) Option

+ func WithGRPCConnection(grpcConn *grpc.ClientConn) Option

+ type PutObjectParams struct

+ func (p *PutObjectParams) WithObject(v *object.Object) *PutObjectParams

+ func (p *PutObjectParams) WithPayloadReader(v io.Reader) *PutObjectParams

+ type RangeChecksumParams struct

+ func (p *RangeChecksumParams) WithAddress(v *object.Address) *RangeChecksumParams

+ func (p *RangeChecksumParams) WithRangeList(rs ...*object.Range) *RangeChecksumParams

+ func (p *RangeChecksumParams) WithSalt(v []byte) *RangeChecksumParams

+ type RangeDataParams struct

+ func (p *RangeDataParams) WithAddress(v *object.Address) *RangeDataParams

+ func (p *RangeDataParams) WithDataWriter(v io.Writer) *RangeDataParams

+ func (p *RangeDataParams) WithRange(v *object.Range) *RangeDataParams

+ type SearchObjectParams struct

+ func (p *SearchObjectParams) WithContainerID(v *container.ID) *SearchObjectParams

+ func (p *SearchObjectParams) WithSearchFilters(v object.SearchFilters) *SearchObjectParams

+ type TransportInfo struct

+ Protocol TransportProtocol

+ Version *pkg.Version

+ type TransportProtocol uint32

+ const GRPC

+ const Unknown