Documentation ¶
Index ¶
- func Run(args []string) int
- type LocalStorageStateBackend
- type RPCHandler
- func (h *RPCHandler) Bind()
- func (h *RPCHandler) HandleProcDone(req *rpc.AbstractRequest) error
- func (h *RPCHandler) HandleProcRegisterStopHook(req *rpc.AbstractRequest) error
- func (h *RPCHandler) HandleStateGet(req *rpc.AbstractRequest) (any, error)
- func (h *RPCHandler) HandleStateRemove(req *rpc.AbstractRequest) (any, error)
- func (h *RPCHandler) HandleStateSet(req *rpc.AbstractRequest) (any, error)
- func (h *RPCHandler) HandleStatusPush(req *rpc.AbstractRequest) error
- type StateBackend
- type StateStore
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type LocalStorageStateBackend ¶
type LocalStorageStateBackend struct {
// contains filtered or unexported fields
}
func NewLocalStorageStateBackend ¶
func NewLocalStorageStateBackend(path string) *LocalStorageStateBackend
func (*LocalStorageStateBackend) LoadStates ¶
func (b *LocalStorageStateBackend) LoadStates() (map[string]string, error)
func (*LocalStorageStateBackend) SaveStates ¶
func (b *LocalStorageStateBackend) SaveStates(state map[string]string) error
type RPCHandler ¶
type RPCHandler struct {
// contains filtered or unexported fields
}
func NewRPCHandler ¶
func NewRPCHandler(s *rpc.Server, msgChan chan outbound.OutboundMessage, states *StateStore, cancelFn func()) *RPCHandler
func (*RPCHandler) Bind ¶
func (h *RPCHandler) Bind()
func (*RPCHandler) HandleProcDone ¶
func (h *RPCHandler) HandleProcDone(req *rpc.AbstractRequest) error
func (*RPCHandler) HandleProcRegisterStopHook ¶
func (h *RPCHandler) HandleProcRegisterStopHook(req *rpc.AbstractRequest) error
func (*RPCHandler) HandleStateGet ¶
func (h *RPCHandler) HandleStateGet(req *rpc.AbstractRequest) (any, error)
func (*RPCHandler) HandleStateRemove ¶
func (h *RPCHandler) HandleStateRemove(req *rpc.AbstractRequest) (any, error)
func (*RPCHandler) HandleStateSet ¶
func (h *RPCHandler) HandleStateSet(req *rpc.AbstractRequest) (any, error)
func (*RPCHandler) HandleStatusPush ¶
func (h *RPCHandler) HandleStatusPush(req *rpc.AbstractRequest) error
type StateBackend ¶
type StateStore ¶
type StateStore struct {
// contains filtered or unexported fields
}
func NewStateStore ¶
func NewStateStore(backend StateBackend) *StateStore
func (*StateStore) Remove ¶
func (s *StateStore) Remove(key string) error
func (*StateStore) Set ¶
func (s *StateStore) Set(key, value string) error
Click to show internal directories.
Click to hide internal directories.