service

Documentation

Index

• type ShareService
  • func NewShareService(bServ blockservice.BlockService, avail share.Availability) *ShareService
  • func (s *ShareService) GetShare(ctx context.Context, dah *share.Root, row, col int) (share.Share, error)
  • func (s *ShareService) GetShares(ctx context.Context, root *share.Root) ([][]share.Share, error)
  • func (s *ShareService) GetSharesByNamespace(ctx context.Context, root *share.Root, nID namespace.ID) ([]share.Share, error)
  • func (s *ShareService) Start(context.Context) error
  • func (s *ShareService) Stop(context.Context) error

Types

type ShareService

type ShareService struct {
	share.Availability
	// contains filtered or unexported fields
}

TODO(@Wondertan): Simple thread safety for Start and Stop would not hurt.

func NewShareService

func NewShareService(bServ blockservice.BlockService, avail share.Availability) *ShareService

NewService creates a new basic share.Module.

func (*ShareService) GetShare

func (s *ShareService) GetShare(ctx context.Context, dah *share.Root, row, col int) (share.Share, error)

func (*ShareService) GetShares

func (s *ShareService) GetShares(ctx context.Context, root *share.Root) ([][]share.Share, error)

func (*ShareService) GetSharesByNamespace

func (s *ShareService) GetSharesByNamespace(
	ctx context.Context,
	root *share.Root,
	nID namespace.ID,
) ([]share.Share, error)

GetSharesByNamespace iterates over a square's row roots and accumulates the found shares in the given namespace.ID.

func (*ShareService) Start

func (s *ShareService) Start(context.Context) error

func (*ShareService) Stop

func (s *ShareService) Stop(context.Context) error