bee

Documentation

Index

• type BeeV2
  • func (b *BeeV2) Authenticate(ctx context.Context, password string) (string, error)
  • func (b *BeeV2) DownloadChunk(ctx context.Context, ref swarm.Address) ([]byte, error)
  • func (b *BeeV2) ExpectToHaveFile(ctx context.Context, file File) error
  • func (b *BeeV2) Name() string
  • func (b *BeeV2) NewChunkUploader(ctx context.Context) (*ChunkUploader, error)
  • func (b *BeeV2) RefreshAuthToken(ctx context.Context, token string) (string, error)
  • func (b *BeeV2) Restricted() bool
  • func (b *BeeV2) UploadFile(ctx context.Context, file File) error
  • func (b *BeeV2) UploadRandomFile(ctx context.Context) (File, error)
• type Bees
  • func (bb Bees) Filter(f FilterFunc) (out Bees)
  • func (bb Bees) ForEach(c ConsumeFunc) error
• type CaseOptions
• type CheckCase
  • func NewCheckCase(ctx context.Context, cluster orchestration.Cluster, caseOpts CaseOptions, ...) (*CheckCase, error)
  • func (c *CheckCase) Balances(ctx context.Context) (balances orchestration.NodeGroupBalances, err error)
  • func (c *CheckCase) Bee(index int) *BeeV2
  • func (c *CheckCase) Bees() Bees
  • func (c *CheckCase) LastBee() *BeeV2
  • func (c *CheckCase) RandomBee() *BeeV2
• type ChunkUploader
  • func (c *ChunkUploader) Name() string
  • func (cu *ChunkUploader) UploadRandomChunk() (*chunkV2, error)
• type ConsumeFunc
• type File
• type FilterFunc

Types

type BeeV2

type BeeV2 struct {
	Addr swarm.Address
	// contains filtered or unexported fields
}

func (*BeeV2) Authenticate

func (b *BeeV2) Authenticate(ctx context.Context, password string) (string, error)

func (*BeeV2) DownloadChunk

func (b *BeeV2) DownloadChunk(ctx context.Context, ref swarm.Address) ([]byte, error)

func (*BeeV2) ExpectToHaveFile

func (b *BeeV2) ExpectToHaveFile(ctx context.Context, file File) error

func (*BeeV2) Name

func (b *BeeV2) Name() string

func (*BeeV2) NewChunkUploader

func (b *BeeV2) NewChunkUploader(ctx context.Context) (*ChunkUploader, error)

func (*BeeV2) RefreshAuthToken

func (b *BeeV2) RefreshAuthToken(ctx context.Context, token string) (string, error)

func (*BeeV2) Restricted

func (b *BeeV2) Restricted() bool

func (*BeeV2) UploadFile

func (b *BeeV2) UploadFile(ctx context.Context, file File) error

func (*BeeV2) UploadRandomFile

func (b *BeeV2) UploadRandomFile(ctx context.Context) (File, error)

NewRandomFile returns new pseudorandom file

type Bees

type Bees []BeeV2

func (Bees) Filter

func (bb Bees) Filter(f FilterFunc) (out Bees)

func (Bees) ForEach

func (bb Bees) ForEach(c ConsumeFunc) error

type CaseOptions

type CaseOptions struct {
	FileName      string
	FileSize      int64
	GasPrice      string
	PostageAmount int64
	PostageLabel  string
	Seed          int64
	PostageDepth  uint64

	AdminPassword       string
	RestrictedGroupName string
	Role                string
}

type CheckCase

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

func NewCheckCase

func NewCheckCase(ctx context.Context, cluster orchestration.Cluster, caseOpts CaseOptions, logger logging.Logger) (*CheckCase, error)

func (*CheckCase) Balances

func (c *CheckCase) Balances(ctx context.Context) (balances orchestration.NodeGroupBalances, err error)

func (*CheckCase) Bee

func (c *CheckCase) Bee(index int) *BeeV2

func (*CheckCase) Bees

func (c *CheckCase) Bees() Bees

func (*CheckCase) LastBee

func (c *CheckCase) LastBee() *BeeV2

func (*CheckCase) RandomBee

func (c *CheckCase) RandomBee() *BeeV2

type ChunkUploader

type ChunkUploader struct {
	Overlay string
	// contains filtered or unexported fields
}

func (*ChunkUploader) Name

func (c *ChunkUploader) Name() string

func (*ChunkUploader) UploadRandomChunk

func (cu *ChunkUploader) UploadRandomChunk() (*chunkV2, error)

type ConsumeFunc

type ConsumeFunc func(b *BeeV2) error

type File

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

type FilterFunc

type FilterFunc func(b *BeeV2) bool