frostfs

Documentation

Index

• type AuthmateFrostFS
  • func NewAuthmateFrostFS(p *pool.Pool) *AuthmateFrostFS
  • func (x *AuthmateFrostFS) ContainerExists(ctx context.Context, idCnr cid.ID) error
  • func (x *AuthmateFrostFS) CreateContainer(ctx context.Context, prm authmate.PrmContainerCreate) (cid.ID, error)
  • func (x *AuthmateFrostFS) CreateObject(ctx context.Context, prm tokens.PrmObjectCreate) (oid.ID, error)
  • func (x *AuthmateFrostFS) ReadObjectPayload(ctx context.Context, addr oid.Address) ([]byte, error)
  • func (x *AuthmateFrostFS) TimeToEpoch(ctx context.Context, futureTime time.Time) (uint64, uint64, error)
• type FrostFS
  • func NewFrostFS(p *pool.Pool) *FrostFS
  • func (x *FrostFS) Container(ctx context.Context, idCnr cid.ID) (*container.Container, error)
  • func (x *FrostFS) ContainerEACL(ctx context.Context, id cid.ID) (*eacl.Table, error)
  • func (x *FrostFS) CreateContainer(ctx context.Context, prm layer.PrmContainerCreate) (cid.ID, error)
  • func (x *FrostFS) CreateObject(ctx context.Context, prm layer.PrmObjectCreate) (oid.ID, error)
  • func (x *FrostFS) DeleteContainer(ctx context.Context, id cid.ID, token *session.Container) error
  • func (x *FrostFS) DeleteObject(ctx context.Context, prm layer.PrmObjectDelete) error
  • func (x *FrostFS) ReadObject(ctx context.Context, prm layer.PrmObjectRead) (*layer.ObjectPart, error)
  • func (x *FrostFS) SetContainerEACL(ctx context.Context, table eacl.Table, sessionToken *session.Container) error
  • func (x *FrostFS) TimeToEpoch(ctx context.Context, now, futureTime time.Time) (uint64, uint64, error)
  • func (x *FrostFS) UserContainers(ctx context.Context, id user.ID) ([]cid.ID, error)
• type PoolStatistic
  • func NewPoolStatistic(p *pool.Pool) *PoolStatistic
  • func (x *PoolStatistic) Statistic() pool.Statistic
• type ResolverFrostFS
  • func NewResolverFrostFS(p *pool.Pool) *ResolverFrostFS
  • func (x *ResolverFrostFS) SystemDNS(ctx context.Context) (string, error)

Types

type AuthmateFrostFS

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

AuthmateFrostFS is a mediator which implements authmate.FrostFS through pool.Pool.

func NewAuthmateFrostFS

func NewAuthmateFrostFS(p *pool.Pool) *AuthmateFrostFS

NewAuthmateFrostFS creates new AuthmateFrostFS using provided pool.Pool.

func (*AuthmateFrostFS) ContainerExists

func (x *AuthmateFrostFS) ContainerExists(ctx context.Context, idCnr cid.ID) error

ContainerExists implements authmate.FrostFS interface method.

func (*AuthmateFrostFS) CreateContainer

func (x *AuthmateFrostFS) CreateContainer(ctx context.Context, prm authmate.PrmContainerCreate) (cid.ID, error)

CreateContainer implements authmate.FrostFS interface method.

func (*AuthmateFrostFS) CreateObject

func (x *AuthmateFrostFS) CreateObject(ctx context.Context, prm tokens.PrmObjectCreate) (oid.ID, error)

CreateObject implements authmate.FrostFS interface method.

func (*AuthmateFrostFS) ReadObjectPayload

func (x *AuthmateFrostFS) ReadObjectPayload(ctx context.Context, addr oid.Address) ([]byte, error)

ReadObjectPayload implements authmate.FrostFS interface method.

func (*AuthmateFrostFS) TimeToEpoch

func (x *AuthmateFrostFS) TimeToEpoch(ctx context.Context, futureTime time.Time) (uint64, uint64, error)

TimeToEpoch implements authmate.FrostFS interface method.

type FrostFS

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

FrostFS represents virtual connection to the FrostFS network. It is used to provide an interface to dependent packages which work with FrostFS.

func NewFrostFS

func NewFrostFS(p *pool.Pool) *FrostFS

NewFrostFS creates new FrostFS using provided pool.Pool.

func (*FrostFS) Container

func (x *FrostFS) Container(ctx context.Context, idCnr cid.ID) (*container.Container, error)

Container implements frostfs.FrostFS interface method.

func (*FrostFS) ContainerEACL

func (x *FrostFS) ContainerEACL(ctx context.Context, id cid.ID) (*eacl.Table, error)

ContainerEACL implements frostfs.FrostFS interface method.

func (*FrostFS) CreateContainer

func (x *FrostFS) CreateContainer(ctx context.Context, prm layer.PrmContainerCreate) (cid.ID, error)

CreateContainer implements frostfs.FrostFS interface method.

If prm.BasicACL is zero, 'eacl-public-read-write' is used.

func (*FrostFS) CreateObject

func (x *FrostFS) CreateObject(ctx context.Context, prm layer.PrmObjectCreate) (oid.ID, error)

CreateObject implements frostfs.FrostFS interface method.

func (*FrostFS) DeleteContainer

func (x *FrostFS) DeleteContainer(ctx context.Context, id cid.ID, token *session.Container) error

DeleteContainer implements frostfs.FrostFS interface method.

func (*FrostFS) DeleteObject

func (x *FrostFS) DeleteObject(ctx context.Context, prm layer.PrmObjectDelete) error

DeleteObject implements frostfs.FrostFS interface method.

func (*FrostFS) ReadObject

func (x *FrostFS) ReadObject(ctx context.Context, prm layer.PrmObjectRead) (*layer.ObjectPart, error)

ReadObject implements frostfs.FrostFS interface method.

func (*FrostFS) SetContainerEACL

func (x *FrostFS) SetContainerEACL(ctx context.Context, table eacl.Table, sessionToken *session.Container) error

SetContainerEACL implements frostfs.FrostFS interface method.

func (*FrostFS) TimeToEpoch

func (x *FrostFS) TimeToEpoch(ctx context.Context, now, futureTime time.Time) (uint64, uint64, error)

TimeToEpoch implements frostfs.FrostFS interface method.

func (*FrostFS) UserContainers

func (x *FrostFS) UserContainers(ctx context.Context, id user.ID) ([]cid.ID, error)

UserContainers implements frostfs.FrostFS interface method.

type PoolStatistic

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

PoolStatistic is a mediator which implements authmate.FrostFS through pool.Pool.

func NewPoolStatistic

func NewPoolStatistic(p *pool.Pool) *PoolStatistic

NewPoolStatistic creates new PoolStatistic using provided pool.Pool.

func (*PoolStatistic) Statistic

func (x *PoolStatistic) Statistic() pool.Statistic

Statistic implements interface method.

type ResolverFrostFS

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

ResolverFrostFS represents virtual connection to the FrostFS network. It implements resolver.FrostFS.

func NewResolverFrostFS

func NewResolverFrostFS(p *pool.Pool) *ResolverFrostFS

NewResolverFrostFS creates new ResolverFrostFS using provided pool.Pool.

func (*ResolverFrostFS) SystemDNS

func (x *ResolverFrostFS) SystemDNS(ctx context.Context) (string, error)

SystemDNS implements resolver.FrostFS interface method.