provider

Documentation

Index

• func DefaultConfig() *util.ServiceConfig
• type Provider
• type RemoteFlowProvider
  • 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

Functions

func DefaultConfig

func DefaultConfig() *util.ServiceConfig

Types

type Provider

type Provider interface {

	// GetFlow retrieves the flow definition for the specified id
	GetFlow(flowId string) (*definition.Definition, error)
	// AddCompressedFlow adds the flow for a specified id
	AddCompressedFlow(id string, flow string) error
	// AddUnCompressedFlow adds the flow for a specified id
	AddUncompressedFlow(id string, flow []byte) error
	// AddFlowURI adds the flow for a specified uri
	AddFlowURI(id string, uri string) error
}

Provider is the interface that describes an object that can provide flow definitions from a URI

type RemoteFlowProvider

type RemoteFlowProvider struct {
	// contains filtered or unexported fields
}

RemoteFlowProvider is an implementation of FlowProvider service that can access flowes via URI

func NewRemoteFlowProvider

func NewRemoteFlowProvider() *RemoteFlowProvider

NewRemoteFlowProvider creates a RemoteFlowProvider

func (*RemoteFlowProvider) AddCompressedFlow

func (pps *RemoteFlowProvider) AddCompressedFlow(id string, flow string) error

func (*RemoteFlowProvider) AddFlowURI

func (pps *RemoteFlowProvider) AddFlowURI(id string, uri string) error

func (*RemoteFlowProvider) AddUncompressedFlow

func (pps *RemoteFlowProvider) AddUncompressedFlow(id string, flow []byte) error

func (*RemoteFlowProvider) GetFlow

func (pps *RemoteFlowProvider) GetFlow(id string) (*definition.Definition, error)

GetFlow implements flow.Provider.GetFlow

func (*RemoteFlowProvider) Name

func (pps *RemoteFlowProvider) Name() string

func (*RemoteFlowProvider) Start

func (pps *RemoteFlowProvider) Start() error

Start implements util.Managed.Start()

func (*RemoteFlowProvider) Stop

func (pps *RemoteFlowProvider) Stop() error

Stop implements util.Managed.Stop()