writer

type ClientConstructor interface {
	Get(client.NodeInfo) (client.MultiAddressClient, error)
}

type Config struct {
	KeyStorage *objectSvc.KeyStorage

	MaxSizeSrc MaxSizeSource

	LocalStore ObjectStorage

	ContainerSource container.Source

	NetmapSource netmap.Source

	NetmapKeys netmap.AnnouncedKeys

	FormatValidator *object.FormatValidator

	NetworkState netmap.State

	ClientConstructor ClientConstructor

	Logger *logger.Logger

	VerifySessionTokenIssuer bool

	ConfigSource netmap.ConfigSource

	DisableBroadcast bool
}

type ECWriter struct {
	Config        *Config
	PlacementOpts []placement.Option
	Container     containerSDK.Container
	Key           *ecdsa.PrivateKey
	CommonPrm     *objectSvc.CommonPrm
	Relay         func(context.Context, client.NodeInfo, client.MultiAddressClient) error

	ObjectMeta      object.ContentMeta
	ObjectMetaValid bool
	// contains filtered or unexported fields
}

type FormatValidatorConfig interface {
	VerifySessionTokenIssuer() bool
}

type InnerRing interface {
	InnerRingKeys(ctx context.Context) ([][]byte, error)
}

type LocalTarget struct {
	Storage                  ObjectStorage
	Container                containerSDK.Container
	AfterObjectWriteCallback func(*objectSDK.Object)
}

type MaxSizeSource interface {
	// MaxObjectSize returns maximum payload size
	// of physically stored object in system.
	//
	// Must return 0 if value can not be obtained.
	MaxObjectSize(context.Context) (uint64, error)
}

type NodeDescriptor struct {
	Local bool

	Info placement.Node
}

type NodeIterator struct {
	Traversal
	// contains filtered or unexported fields
}

type ObjectStorage interface {
	// Put must save passed object
	// and return any appeared error.
	Put(context.Context, *objectSDK.Object, bool) error
	// Delete must delete passed objects
	// and return any appeared error.
	Delete(ctx context.Context, tombstone oid.Address, toDelete []oid.ID, expEpoch uint64) error
	// Lock must lock passed objects
	// and return any appeared error.
	Lock(ctx context.Context, locker oid.Address, toLock []oid.ID, expEpoch uint64) error
	// IsLocked must clarify object's lock status.
	IsLocked(context.Context, oid.Address) (bool, error)
}

type Option func(*Config)

type Params struct {
	Config *Config

	Common *objectSvc.CommonPrm

	Header *objectSDK.Object

	Container containerSDK.Container

	TraverseOpts []placement.Option

	Relay func(context.Context, client.NodeInfo, client.MultiAddressClient) error

	SignRequestPrivateKey *ecdsa.PrivateKey

	AfterLocalObjectWriteCallback func(*objectSDK.Object)
}

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

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

type Traversal struct {
	Opts []placement.Option

	// need of additional broadcast after the object is saved
	ExtraBroadcastEnabled bool

	// container nodes which was processed during the primary object placement
	Exclude map[string]*bool

	ResetSuccessAfterOnBroadcast bool
}