runtime

package

v1.0.0 Latest Latest Go to latest Published: May 31, 2024 License: GPL-3.0 Imports: 7 Imported by: 0

Details

View Source

const (
	ReqStatus = "status"
	ReqStop   = "stop"
	RespErr   = "error"
	Response  = "response"
)

View Source

var (
	ErrFree    = fmt.Errorf("target is free")
	ErrTimeout = fmt.Errorf("runtime pipeline target timeout")
)

This section is empty.

type Event struct {
	Type string `json:"type"`
	Data string `json:"data"`
}

type EventHandler func(server *RuntimeServer, event *Event)

type RuntimeClient struct {
	Path string
	// contains filtered or unexported fields
}

func NewRuntimeClient(path string) *RuntimeClient

func (c *RuntimeClient) Request(reqtype string) (resp string, err error)

func (c *RuntimeClient) Write(event *Event)

type RuntimeServer struct {
	Path        string
	HandlerFunc EventHandler
	// contains filtered or unexported fields
}

func NewRuntimeServer(path string, handlerFunc EventHandler) *RuntimeServer

func (s *RuntimeServer) Serve()

func (s *RuntimeServer) Shutdown() error

func (s *RuntimeServer) Write(event *Event)