Versions in this module Expand all Collapse all v0 v0.0.2 May 26, 2026 v0.0.1 May 25, 2026 Changes in this version + var Component = &component.Component + type Service struct + func NewService(delayConfig *managerConfig.Delay, manager cluster.Manager, ...) *Service + func (s *Service) Process(_ context.Context) (err error) + func (s *Service) Subscribe(meta *model.Meta, st grpc.ServerStreamingServer[model.Stream]) (err error)
Go to main page