netdriver

Documentation

Index

• func HandleAll(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleCommit(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleDelay(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleGetData(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleGetDelayedStates(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleGetStateByID(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleGetStateByLabels(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleGetStates(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• func HandleStoreData(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool
• type Driver
  • func New(httpHost string) *Driver
  • func (d *Driver) Commit(cmd *flowstate.CommitCommand) error
  • func (d *Driver) Delay(cmd *flowstate.DelayCommand) error
  • func (d *Driver) GetData(cmd *flowstate.GetDataCommand) error
  • func (d *Driver) GetDelayedStates(cmd *flowstate.GetDelayedStatesCommand) error
  • func (d *Driver) GetStateByID(cmd *flowstate.GetStateByIDCommand) error
  • func (d *Driver) GetStateByLabels(cmd *flowstate.GetStateByLabelsCommand) error
  • func (d *Driver) GetStates(cmd *flowstate.GetStatesCommand) error
  • func (d *Driver) Init(_ *flowstate.Engine) error
  • func (d *Driver) StoreData(cmd *flowstate.StoreDataCommand) error

Functions

func HandleAll

func HandleAll(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleCommit

func HandleCommit(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleDelay

func HandleDelay(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleGetData

func HandleGetData(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleGetDelayedStates

func HandleGetDelayedStates(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleGetStateByID

func HandleGetStateByID(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleGetStateByLabels

func HandleGetStateByLabels(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleGetStates

func HandleGetStates(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

func HandleStoreData

func HandleStoreData(rw http.ResponseWriter, r *http.Request, d flowstate.Driver, l *slog.Logger) bool

Types

type Driver

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

func New

func New(httpHost string) *Driver

func (*Driver) Commit

func (d *Driver) Commit(cmd *flowstate.CommitCommand) error

func (*Driver) Delay

func (d *Driver) Delay(cmd *flowstate.DelayCommand) error

func (*Driver) GetData

func (d *Driver) GetData(cmd *flowstate.GetDataCommand) error

func (*Driver) GetDelayedStates

func (d *Driver) GetDelayedStates(cmd *flowstate.GetDelayedStatesCommand) error

func (*Driver) GetStateByID

func (d *Driver) GetStateByID(cmd *flowstate.GetStateByIDCommand) error

func (*Driver) GetStateByLabels

func (d *Driver) GetStateByLabels(cmd *flowstate.GetStateByLabelsCommand) error

func (*Driver) GetStates

func (d *Driver) GetStates(cmd *flowstate.GetStatesCommand) error

func (*Driver) Init

func (d *Driver) Init(_ *flowstate.Engine) error

func (*Driver) StoreData

func (d *Driver) StoreData(cmd *flowstate.StoreDataCommand) error