Versions in this module Expand all Collapse all v0 v0.4.1 Mar 7, 2022 Changes in this version + const SubscriptionFieldFilter + const SubscriptionFieldMode + const SubscriptionFieldPubsubName + const SubscriptionFieldTopic + const SubscriptionModeChanged + const SubscriptionModePeriod + const SubscriptionModeRealtime + const SubscriptionModeUndefine + var ErrSubscriptionInvalid = errors.New("params invalid") + func NewSubscription(ctx context.Context, in *dao.Entity, dispatcher dispatch.Dispatcher, ...) (stateM state.Machiner, err error) + type Base struct + Filter string + Mode string + PubsubName string + Topic string + func (s *Base) Validate() error
Go to main page