Versions in this module Expand all Collapse all v1 v1.2.0 Jan 7, 2020 Changes in this version type BaseRunnableOptions + Logger astikit.StdLogger v1.1.0 Dec 24, 2019 v1.0.1 Dec 5, 2019 v1.0.0 Oct 4, 2019 v0 v0.1.0 Dec 4, 2019 Changes in this version + const IndexIdentifierType + const ListenablesRegisterMessage + const RunnableCrashedMessage + const RunnableDoneMessage + const RunnableIdentifierType + const RunnableStartMessage + const RunnableStartedMessage + const RunnableStopMessage + const RunnableStoppedMessage + const RunningStatus + const StoppedStatus + const UIDisconnectedMessage + const UIIdentifierType + const UIMessageNamesAddMessage + const UIMessageNamesDeleteMessage + const UIPingMessage + const UIRegisterMessage + const UIWelcomeMessage + const WorkerDisconnectedMessage + const WorkerIdentifierType + const WorkerRegisterMessage + const WorkerRegisteredMessage + const WorkerWelcomeMessage + var ErrContextCancelled = errors.New("astibob: context cancelled") + func ContentHandle(path string, c []byte) httprouter.Handle + func DirHandle(path string) httprouter.Handle + func ParseRunnableStartPayload(m *Message) (name string, err error) + func ParseRunnableStopPayload(m *Message) (name string, err error) + func ParseUIDisconnectedPayload(m *Message) (name string, err error) + func ParseUIMessageNamesAddPayload(m *Message) (names []string, err error) + func ParseUIMessageNamesDeletePayload(m *Message) (names []string, err error) + func ParseWorkerDisconnectedPayload(m *Message) (worker string, err error) + func WriteHTTPData(rw http.ResponseWriter, data interface{}) + func WriteHTTPError(rw http.ResponseWriter, code int, err error) + type BaseOperatable struct + func NewBaseOperatable() *BaseOperatable + func (o *BaseOperatable) AddRoute(path, method string, h httprouter.Handle) + func (o *BaseOperatable) AddTemplate(n string, c []byte) + func (o *BaseOperatable) Routes() map[string]map[string]httprouter.Handle + func (o *BaseOperatable) Templates() map[string][]byte + type BaseRunnable struct + func NewBaseRunnable(o BaseRunnableOptions) *BaseRunnable + func (r *BaseRunnable) Dispatch(m *Message) + func (r *BaseRunnable) Metadata() Metadata + func (r *BaseRunnable) NewTask() *astiworker.Task + func (r *BaseRunnable) OnMessage(m *Message) (err error) + func (r *BaseRunnable) RootCtx() context.Context + func (r *BaseRunnable) SetDispatchFunc(f DispatchFunc) + func (r *BaseRunnable) SetRootCtx(ctx context.Context) + func (r *BaseRunnable) SetTaskFunc(f astiworker.TaskFunc) + func (r *BaseRunnable) Start(ctx context.Context) (err error) + func (r *BaseRunnable) Status() string + func (r *BaseRunnable) Stop() + type BaseRunnableOptions struct + Metadata Metadata + OnMessage func(m *Message) error + OnStart func(ctx context.Context) error + type DispatchConditions struct + From *Identifier + Name *string + Names map[string]bool + To *Identifier + type DispatchFunc func(m *Message) + type Dispatcher struct + func NewDispatcher(ctx context.Context, t astiworker.TaskFunc) *Dispatcher + func (d *Dispatcher) Close() + func (d *Dispatcher) Dispatch(m *Message) + func (d *Dispatcher) On(c DispatchConditions, h MessageHandler) + type Error struct + Message string + type Identifier struct + Name *string + Type string + Types map[string]bool + Worker *string + func NewIndexIdentifier() *Identifier + func NewRunnableIdentifier(runnable, worker string) *Identifier + func NewUIIdentifier(name string) *Identifier + func NewWorkerIdentifier(name string) *Identifier + func (i Identifier) Clone() (o *Identifier) + func (i Identifier) WorkerName() string + type Listenable interface + MessageNames func() []string + OnMessage func(m *Message) error + type Listenables struct + Names []string + Runnable string + func ParseListenablesRegisterPayload(m *Message) (l Listenables, err error) + type Message struct + From Identifier + ID int + Name string + Payload json.RawMessage + To *Identifier + func NewListenablesRegisterMessage(from Identifier, to *Identifier, l Listenables) (m *Message, err error) + func NewMessage() *Message + func NewRunnableCrashedMessage(from Identifier, to *Identifier) *Message + func NewRunnableDoneMessage(to *Identifier, d RunnableDone) (m *Message, err error) + func NewRunnableStartedMessage(from Identifier, to *Identifier) *Message + func NewRunnableStoppedMessage(from Identifier, to *Identifier) *Message + func NewUIDisconnectedMessage(from Identifier, to *Identifier, name string) (m *Message, err error) + func NewUIMessageNamesAddMessage(from Identifier, to *Identifier, names []string) (m *Message, err error) + func NewUIMessageNamesDeleteMessage(from Identifier, to *Identifier, names []string) (m *Message, err error) + func NewUIWelcomeMessage(from Identifier, to *Identifier, w WelcomeUI) (m *Message, err error) + func NewWorkerDisconnectedMessage(from Identifier, to *Identifier, worker string) (m *Message, err error) + func NewWorkerRegisterMessage(from Identifier, to *Identifier, w Worker) (m *Message, err error) + func NewWorkerRegisteredMessage(from Identifier, to *Identifier, w Worker) (m *Message, err error) + func NewWorkerWelcomeMessage(from Identifier, to *Identifier, w WelcomeWorker) (m *Message, err error) + func (m *Message) Clone() (o *Message) + type MessageHandler func(m *Message) error + type Metadata struct + Description string + Name string + type Operatable interface + Routes func() map[string]map[string]httprouter.Handle + Templates func() map[string][]byte + type Runnable interface + Metadata func() Metadata + OnMessage func(m *Message) error + SetDispatchFunc func(f DispatchFunc) + SetRootCtx func(ctx context.Context) + SetTaskFunc func(f astiworker.TaskFunc) + Start func(ctx context.Context) error + Status func() string + Stop func() + type RunnableDone struct + ID int + Success bool + func ParseRunnableDonePayload(m *Message) (d RunnableDone, err error) + type RunnableMessage struct + Status string + WebHomepage string + type ServerOptions struct + Addr string + Password string + Username string + type UI struct + MessageNames []string + Name string + func ParseUIRegisterPayload(m *Message) (u UI, err error) + type WelcomeUI struct + Name string + Workers []Worker + type WelcomeWorker struct + UIMessageNames []string + Workers []Worker + func ParseWorkerWelcomePayload(m *Message) (w WelcomeWorker, err error) + type Worker struct + Addr string + Name string + Runnables []RunnableMessage + func ParseWorkerRegisterPayload(m *Message) (w Worker, err error) + func ParseWorkerRegisteredPayload(m *Message) (w Worker, err error)
Go to main page