localfiber

Documentation

Index

• func NewFiberClient(ctx context.Context, cfg Config) (*fibre.Client, error)
• func NewFiberClientWithKeyring(ctx context.Context, kr keyring.Keyring, cfg Config) (*fibre.Client, error)
• func NewKeyring(keyringPath, keyName, chainID string) (keyring.Keyring, error)
• type Adapter
  • func NewAdapter(c *fibre.Client) *Adapter
  • func (a *Adapter) Download(ctx context.Context, blobID block.FiberBlobID) ([]byte, error)
  • func (a *Adapter) Listen(_ context.Context, _ []byte) (<-chan block.FiberBlobEvent, error)
  • func (a *Adapter) Upload(ctx context.Context, namespace []byte, data []byte) (block.FiberUploadResult, error)
• type Config

Functions

func NewFiberClient

func NewFiberClient(ctx context.Context, cfg Config) (*fibre.Client, error)

func NewFiberClientWithKeyring

func NewFiberClientWithKeyring(ctx context.Context, kr keyring.Keyring, cfg Config) (*fibre.Client, error)

func NewKeyring

func NewKeyring(keyringPath, keyName, chainID string) (keyring.Keyring, error)

Types

type Adapter

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

func NewAdapter

func NewAdapter(c *fibre.Client) *Adapter

func (*Adapter) Download

func (a *Adapter) Download(ctx context.Context, blobID block.FiberBlobID) ([]byte, error)

func (*Adapter) Listen

func (a *Adapter) Listen(_ context.Context, _ []byte) (<-chan block.FiberBlobEvent, error)

func (*Adapter) Upload

func (a *Adapter) Upload(ctx context.Context, namespace []byte, data []byte) (block.FiberUploadResult, error)

type Config

type Config struct {
	KeyringPath  string
	KeyName      string
	StateAddress string
	ChainID      string
	UploadConc   int
	DownloadConc int
}