Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { PostgresURI string PinnerMultiaddr string IpfsMaddrs []multiaddr.Multiaddr DaemonFrequency time.Duration ExportMetricsFrequency time.Duration TargetSectorSize int64 BatchMinSize int64 BatchMinWaiting time.Duration BatchWaitScalingFactor int64 CARUploader packer.CARUploader CARExportURL string }
Config defines params for Service configuration.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service is a gRPC service wrapper around an packer.
func (*Service) OnReadyToBatch ¶
func (s *Service) OnReadyToBatch(ctx context.Context, opID mbroker.OperationID, srs []mbroker.ReadyToBatchData) error
OnReadyToBatch process a message for data ready to be included in a batch.
Click to show internal directories.
Click to hide internal directories.