Versions in this module Expand all Collapse all v1 v1.2.1 Aug 20, 2020 v1.2.0 Aug 20, 2020 Changes in this version + type MconfigProvider struct + func (p *MconfigProvider) GetStreamName() string + func (p *MconfigProvider) GetUpdates(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error) + type StreamProvider interface + GetStreamName func() string + GetUpdates func(gatewayId string, extraArgs *any.Any) ([]*protos.DataUpdate, error) + func GetStreamProvider(streamName string) (StreamProvider, error) + func NewRemoteProvider(serviceName, stream string) StreamProvider
Go to main page