syncer

May 29, 2024

Changes in this version

+ var SourcesSubscriber subscribers.SubscriberType = "sources"

+ func InjectSubscribers(service *Service, network utils.Network, networkId utils.NetworkID) error

+ func RegisterService(ctx *cli.Context, baseService service.Service) (service.Service, error)

+ type Service struct

+ func NewService(ctx *cli.Context, baseService *service.BaseService) (*Service, error)

+ func (s *Service) Dependencies() map[service.DependencyName]service.Option

+ func (s *Service) Start(network utils.Network, networkId utils.NetworkID) error

+ func (s *Service) Stop() error

+ type SourcesInterceptor struct

+ func NewSourcesInterceptor(ctx context.Context, svc *Service, opts *options.Subscriber) (*SourcesInterceptor, error)

+ func (i *SourcesInterceptor) Ch() chan *events.UnpackSources

+ func (i *SourcesInterceptor) QueueSourceFn(network utils.Network, networkId utils.NetworkID, ...) subscribers.SourcesHookFn

+ func (i *SourcesInterceptor) Start() error

+ func (i *SourcesInterceptor) Stop() error

+ func (i *SourcesInterceptor) Unpack(event *events.UnpackSources) error