mgmt

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

type EventsStreamPayload struct {
	ProcessID string `msgpack:"pid"`
	Type      string `msgpack:"t"`
	Timestamp int64  `msgpack:"ts"`
	Summary   string `msgpack:"sum"`
}

type EventsSubscribePayload struct{}

type ListEntry struct {
	ID       string `msgpack:"id"`
	Name     string `msgpack:"name"`
	State    string `msgpack:"state"`
	ChildPID int    `msgpack:"pid"`
	RSS      uint64 `msgpack:"rss"`
}

type ListResponsePayload struct {
	Entries []ListEntry `msgpack:"entries"`
}

type LogsRequestPayload struct {
	ID     string `msgpack:"id"`
	Stream uint8  `msgpack:"s"`
}

type LogsStreamPayload struct {
	ID     string `msgpack:"id"`
	Stream uint8  `msgpack:"s"`
	Data   []byte `msgpack:"d"`
	EOF    bool   `msgpack:"eof"`
}

type ManagerAPI interface {
	List() []ListEntry
	StatusOf(id string) (ListEntry, error)
	Stop(ctx context.Context, id string) error
}

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

type ServerOptions struct {
	SocketPath string
	Manager    ManagerAPI
	SpillerDir string
}

type StartRequestPayload struct {
	ID string `msgpack:"id"`
}

type StatusRequestPayload struct {
	ID string `msgpack:"id"`
}

type StatusResponsePayload struct {
	Entry ListEntry `msgpack:"entry"`
	Err   string    `msgpack:"err"`
}

type StopRequestPayload struct {
	ID string `msgpack:"id"`
}