Documentation
¶
Index ¶
- Constants
- func Build(wfConf *WorkflowConfig, connMap *map[int64]*QuicConn) ([]yomo.FlowFunc, []yomo.SinkFunc)
- func DispatcherWithFunc(flows []yomo.FlowFunc, reader io.Reader) rx.RxStream
- func GetSinks(wfConf *WorkflowConfig, connMap *map[int64]*QuicConn) []yomo.SinkFunc
- func Register(ext string, s Serverless)
- func Start(endpoint string, handler quic.ServerHandler) error
- type App
- type Options
- type QuicConn
- type QuicHandler
- type Serverless
- type Workflow
- type WorkflowConfig
Constants ¶
View Source
const ( StreamTypeSource string = "source" StreamTypeFlow string = "flow" StreamTypeSink string = "sink" StreamTypeZipperSender string = "zipper-sender" )
Variables ¶
This section is empty.
Functions ¶
func DispatcherWithFunc ¶
DispatcherWithFunc dispatches the input stream to downstreams.
func GetSinks ¶
func GetSinks(wfConf *WorkflowConfig, connMap *map[int64]*QuicConn) []yomo.SinkFunc
GetSinks get sinks from config and connMap
func Register ¶
func Register(ext string, s Serverless)
Types ¶
type QuicConn ¶
type QuicConn struct {
Session quic.Session
Signal quic.Stream
Stream io.ReadWriter
StreamType string
Name string
Heartbeat chan byte
IsClosed bool
Ready bool
}
QuicConn represents the QUIC connection.
func (*QuicConn) Beat ¶
func (c *QuicConn) Beat()
Beat sends the heartbeat to clients and checks if receiving the heartbeat back.
func (*QuicConn) SendSignal ¶
SendSignal sends the signal to clients.
type QuicHandler ¶
type QuicHandler struct {
// contains filtered or unexported fields
}
func NewQuicHandler ¶
func NewQuicHandler(conf *WorkflowConfig, meshConfURL string) *QuicHandler
func (*QuicHandler) GetZipperSenders ¶
func (s *QuicHandler) GetZipperSenders() error
GetZipperSenders connects to downstream zippers and get Zipper-Senders.
func (*QuicHandler) Listen ¶
func (s *QuicHandler) Listen() error
type Serverless ¶
func Create ¶
func Create(opts *Options) (Serverless, error)
type WorkflowConfig ¶
type WorkflowConfig struct {
Name string `yaml:"name"`
Host string `yaml:"host"`
Port int `yaml:"port"`
Workflow `yaml:",inline"`
}
func Load ¶
func Load(path string) (*WorkflowConfig, error)
func ParseConfig ¶
func ParseConfig(config string) (*WorkflowConfig, error)
Click to show internal directories.
Click to hide internal directories.