Versions in this module Expand all Collapse all v0 v0.5.1 Feb 1, 2018 Changes in this version + func DefaultConfig() *util.ServiceConfig + type Provider interface + AddCompressedFlow func(id string, flow string) error + AddFlowURI func(id string, uri string) error + AddUncompressedFlow func(id string, flow []byte) error + GetFlow func(flowId string) (*definition.Definition, error) + type RemoteFlowProvider struct + func NewRemoteFlowProvider() *RemoteFlowProvider + func (pps *RemoteFlowProvider) AddCompressedFlow(id string, flow string) error + func (pps *RemoteFlowProvider) AddFlowURI(id string, uri string) error + func (pps *RemoteFlowProvider) AddUncompressedFlow(id string, flow []byte) error + func (pps *RemoteFlowProvider) GetFlow(id string) (*definition.Definition, error) + func (pps *RemoteFlowProvider) Name() string + func (pps *RemoteFlowProvider) Start() error + func (pps *RemoteFlowProvider) Stop() error
Go to main page