Versions in this module Expand all Collapse all v0 v0.10.0 Jul 10, 2020 Changes in this version + const BearerToken + const ErrIncompleteSGInfo + const ExtendedHeaders + const PublicSessionToken + func ExtendedACLSourceFromBinary(v acl.BinaryExtendedACLSource) (acl.ExtendedACLSource, error) + func NewLocalHeadIntegrityVerifier(keyVerifier core.OwnerKeyVerifier) (objutil.Verifier, error) + func NewLocalIntegrityVerifier(keyVerifier core.OwnerKeyVerifier) (objutil.Verifier, error) + func NewObjectLocator(p LocatorParams) (replication.ObjectLocator, error) + func NewObjectValidator(p *ObjectValidatorParams) (replication.ObjectVerifier, error) + func NewPayloadVerifier() objutil.Verifier + func NewStorageGroupInfoReceiver(p StorageGroupInfoReceiverParams) (storagegroup.InfoReceiver, error) + type ACLHelper interface + func NewACLHelper(cnr container.Storage) (ACLHelper, error) + type Address = refs.Address + type AddressStore interface + SelfAddr func() (multiaddr.Multiaddr, error) + type AddressStoreComponent interface + func NewAddressStore(ps peers.Store, log *zap.Logger) (AddressStoreComponent, error) + type BalanceOfParams struct + func (s *BalanceOfParams) SetOwnerID(v refs.OwnerID) + func (s BalanceOfParams) OwnerID() refs.OwnerID + type BalanceOfResult struct + func (s *BalanceOfResult) SetAmount(v int64) + func (s BalanceOfResult) Amount() int64 + type BasicACLGetter interface + GetBasicACL func(context.Context, CID) (uint32, error) + type CID = refs.CID + type ContainerInvolvementChecker interface + IsContainerNode func(ctx context.Context, addr multiaddr.Multiaddr, cid CID, previousNetMap bool) (bool, error) + type ContainerNodesLister interface + ContainerNodes func(ctx context.Context, cid CID) ([]multiaddr.Multiaddr, error) + ContainerNodesInfo func(ctx context.Context, cid CID, prev int) ([]bootstrap.NodeInfo, error) + type ContainerOwnerChecker interface + IsContainerOwner func(context.Context, CID, refs.OwnerID) (bool, error) + type ContainerTraverseExecutor interface + Execute func(context.Context, TraverseParams) + func NewContainerTraverseExecutor(t transport.ObjectTransport) (ContainerTraverseExecutor, error) + type DecimalsParams struct + type DecimalsResult struct + func (s *DecimalsResult) SetDecimals(v int64) + func (s DecimalsResult) Decimals() int64 + type EpochReceiver interface + Epoch func() uint64 + type GetParams struct + Handler func(multiaddr.Multiaddr, *object.Object) + func (s *GetParams) HandleResult(_ context.Context, node multiaddr.Multiaddr, r interface{}, e error) + type HeadParams struct + FullHeaders bool + type LocatorParams struct + Logger *zap.Logger + SelectiveContainerExecutor SelectiveContainerExecutor + type MorphBalanceContract struct + func (s *MorphBalanceContract) SetBalanceContractClient(v StaticContractClient) + func (s *MorphBalanceContract) SetBalanceOfMethodName(v string) + func (s *MorphBalanceContract) SetDecimalsMethodName(v string) + func (s MorphBalanceContract) BalanceOf(p BalanceOfParams) (*BalanceOfResult, error) + func (s MorphBalanceContract) Decimals(DecimalsParams) (*DecimalsResult, error) + type MorphContainerContract struct + func (s *MorphContainerContract) DeleteContainer(p container.DeleteParams) (*container.DeleteResult, error) + func (s *MorphContainerContract) GetBinaryEACL(_ context.Context, key acl.BinaryEACLKey) (acl.BinaryEACLValue, error) + func (s *MorphContainerContract) GetContainer(p container.GetParams) (*container.GetResult, error) + func (s *MorphContainerContract) ListContainers(p container.ListParams) (*container.ListResult, error) + func (s *MorphContainerContract) PutBinaryEACL(_ context.Context, key acl.BinaryEACLKey, val acl.BinaryEACLValue) error + func (s *MorphContainerContract) PutContainer(p container.PutParams) (*container.PutResult, error) + func (s *MorphContainerContract) SetContainerContractClient(v StaticContractClient) + func (s *MorphContainerContract) SetContainerDeleteMethodName(v string) + func (s *MorphContainerContract) SetContainerGetMethodName(v string) + func (s *MorphContainerContract) SetContainerListMethodName(v string) + func (s *MorphContainerContract) SetContainerPutMethodName(v string) + func (s *MorphContainerContract) SetEACLGetMethodName(v string) + func (s *MorphContainerContract) SetEACLSetMethodName(v string) + type MorphNetmapContract struct + func (s *MorphNetmapContract) AddPeer(p boot.BootstrapPeerParams) error + func (s *MorphNetmapContract) GetIRInfo(ir.GetInfoParams) (*ir.GetInfoResult, error) + func (s *MorphNetmapContract) GetNetMap(p netmap.GetParams) (*netmap.GetResult, error) + func (s *MorphNetmapContract) SetAddPeerMethodName(v string) + func (s *MorphNetmapContract) SetIRListMethodName(v string) + func (s *MorphNetmapContract) SetNetMapMethodName(v string) + func (s *MorphNetmapContract) SetNetmapContractClient(v StaticContractClient) + func (s *MorphNetmapContract) SetNewEpochMethodName(v string) + func (s *MorphNetmapContract) SetUpdateStateMethodName(v string) + func (s *MorphNetmapContract) UpdateEpoch(p UpdateEpochParams) error + func (s *MorphNetmapContract) UpdateState(p UpdateStateParams) error + type MorphReputationContract struct + func (s *MorphReputationContract) SetListMethodName(v string) + func (s *MorphReputationContract) SetPublicKeyStore(v peers.PublicKeyStore) + func (s *MorphReputationContract) SetPutMethodName(v string) + func (s *MorphReputationContract) SetReputationContractClient(v StaticContractClient) + type Netmap = netmap.NetMap + type NodePublicKeyReceiver interface + PublicKey func(multiaddr.Multiaddr) *ecdsa.PublicKey + type NodeState int64 + const StateOffline + func (s NodeState) Int64() int64 + type Object = object.Object + type ObjectContainerHandlerParams struct + Executor ContainerTraverseExecutor + NodeLister ContainerNodesLister + type ObjectID = refs.ObjectID + type ObjectPlacer interface + Epoch func() uint64 + GetNodes func(ctx context.Context, addr Address, usePreviousNetMap bool, ...) ([]multiaddr.Multiaddr, error) + func NewObjectPlacer(pl placement.Component) (ObjectPlacer, error) + type ObjectStorage interface + func NewObjectStorage(p ObjectStorageParams) (ObjectStorage, error) + type ObjectStorageParams struct + Localstore localstore.Localstore + Logger *zap.Logger + SelectiveContainerExecutor SelectiveContainerExecutor + type ObjectValidatorParams struct + AddressStore AddressStore + Localstore localstore.Localstore + Logger *zap.Logger + MaxPayloadRangeSize uint64 + PayloadRangeCount int + Salitor Salitor + SaltSize int + SelectiveContainerExecutor SelectiveContainerExecutor + Verifier objutil.Verifier + type ProgressControlFlag int + const BreakProgress + const NextAddress + const NextNode + type PutParams struct + CopiesNumber uint32 + Handler func(multiaddr.Multiaddr, bool) + Object *object.Object + func (s *PutParams) HandleResult(_ context.Context, node multiaddr.Multiaddr, _ interface{}, e error) + type RangeHashParams struct + Handler func(multiaddr.Multiaddr, []hash.Hash) + Ranges []object.Range + Salt []byte + func (s *RangeHashParams) HandleResult(_ context.Context, node multiaddr.Multiaddr, r interface{}, e error) + type SGID = refs.SGID + type Salitor func(data, salt []byte) []byte + type SearchParams struct + Handler func(multiaddr.Multiaddr, []refs.Address) + SearchCID refs.CID + SearchQuery []byte + func (s *SearchParams) HandleResult(_ context.Context, node multiaddr.Multiaddr, r interface{}, e error) + type SelectiveContainerExecutor interface + Get func(context.Context, *GetParams) error + Head func(context.Context, *HeadParams) error + Put func(context.Context, *PutParams) error + RangeHash func(context.Context, *RangeHashParams) error + Search func(context.Context, *SearchParams) error + func NewObjectContainerHandler(p ObjectContainerHandlerParams) (SelectiveContainerExecutor, error) + type SelectiveParams struct + Bearer service.BearerToken + Breaker func(refs.Address) ProgressControlFlag + ExtendedHeaders []service.ExtendedHeader + IDList []refs.ObjectID + Nodes []multiaddr.Multiaddr + Query []byte + Raw bool + ServeLocal bool + TTL uint32 + Token service.SessionToken + type StaticContractClient struct + func NewStaticContractClient(client *goclient.Client, scHash util.Uint160, fee util.Fixed8) (StaticContractClient, error) + func (s StaticContractClient) Invoke(method string, args ...interface{}) error + func (s StaticContractClient) TestInvoke(method string, args ...interface{}) ([]sc.Parameter, error) + type StorageGroupInfoReceiverParams struct + Logger *zap.Logger + SelectiveContainerExecutor SelectiveContainerExecutor + type TraverseParams struct + ExecutionInterceptor func(context.Context, multiaddr.Multiaddr) bool + Handler transport.ResultHandler + TransportInfo transport.MetaInfo + Traverser Traverser + WorkerPool WorkerPool + type Traverser interface + Next func(context.Context) []multiaddr.Multiaddr + type UpdateEpochParams struct + func (s *UpdateEpochParams) SetNumber(v uint64) + func (s UpdateEpochParams) Number() uint64 + type UpdateStateParams struct + func (s *UpdateStateParams) SetKey(v []byte) + func (s *UpdateStateParams) SetState(v NodeState) + func (s UpdateStateParams) Key() []byte + func (s UpdateStateParams) State() NodeState + type WorkerPool interface + Submit func(func()) error
Go to main page