Documentation
¶
Index ¶
Constants ¶
View Source
const CTRL_ROOTURL string = `/_/`
View Source
const DEFAULT_PORT uint = 17779
View Source
const OPWIRE_EDITION_PREFIX string = "OPWIRE_EDITION"
View Source
const OPWIRE_REQUEST_PREFIX string = "OPWIRE_REQUEST"
View Source
const OPWIRE_SETTINGS_PREFIX string = "OPWIRE_SETTINGS"
Variables ¶
View Source
var ACCEPTED_METHODS []string = []string{ http.MethodGet, http.MethodPost, http.MethodPut, http.MethodPatch, http.MethodDelete, }
Functions ¶
This section is empty.
Types ¶
type AgentServer ¶
type AgentServer struct {
// contains filtered or unexported fields
}
func NewAgentServer ¶
func NewAgentServer(c *ServerOptions) (s *AgentServer, err error)
func (*AgentServer) Shutdown ¶
func (s *AgentServer) Shutdown() error
func (*AgentServer) Start ¶
func (s *AgentServer) Start() error
type CommandExecutor ¶ added in v1.0.4
type CommandExecutor interface {
Register(*invokers.CommandDescriptor, ...string) error
StoreSettings(prefix string, settings map[string]interface{}, format string, resourceName string) error
Run(*bytes.Buffer, *invokers.CommandInvocation, *bytes.Buffer, *bytes.Buffer) (*invokers.ExecutionState, error)
}
type ReqSerializer ¶
type ReqSerializer struct{}
func NewReqSerializer ¶
func NewReqSerializer() (*ReqSerializer, error)
func (*ReqSerializer) Decode ¶
func (s *ReqSerializer) Decode(data []byte) (*RequestPacket, error)
type RequestPacket ¶
type ServerEdition ¶
type ServerOptions ¶
type StateStore ¶
type StateStore struct {
// contains filtered or unexported fields
}
func NewStateStore ¶
func NewStateStore() (*StateStore, error)
func (*StateStore) Get ¶
func (ss *StateStore) Get(key string) interface{}
func (*StateStore) Store ¶
func (ss *StateStore) Store(key string, val interface{}) *StateStore
Click to show internal directories.
Click to hide internal directories.