Versions in this module Expand all Collapse all v0 v0.48.86 Oct 24, 2023 v0.48.84 Oct 24, 2023 Changes in this version + const OptStoreStreamers + const OptStreamersFileFsync + const OptStreamersFileOutputMetadata + const OptStreamersFilePrefix + const OptStreamersFileStopNodeOnError + const OptStreamersFileWriteDir + var ServiceConstructorLookupTable = map[ServiceType]ServiceConstructor + func LoadStreamingServices(appOpts serverTypes.AppOptions, appCodec types.Codec, logger log.Logger, ...) ([]types.StreamingService, *sync.WaitGroup, error) + func NewFileStreamingService(opts serverTypes.AppOptions, keys []types.StoreKey, marshaller types.Codec, ...) (types.StreamingService, error) + type ServiceConstructor func(serverTypes.AppOptions, []types.StoreKey, types.Codec, log.Logger) (types.StreamingService, error) + func NewServiceConstructor(name string) (ServiceConstructor, error) + type ServiceType int + const File + const Unknown + func ServiceTypeFromString(name string) ServiceType + func (sst ServiceType) String() string
Go to main page