Documentation
¶
Index ¶
Constants ¶
View Source
const CTRL_BASEURL string = `/_/`
View Source
const DEFAULT_PORT uint = 17779
View Source
const EXEC_BASEURL string = `/run`
View Source
const OPWIRE_EDITION_PREFIX string = "OPWIRE_EDITION"
View Source
const OPWIRE_EDITION_PREFIX_PLUS string = OPWIRE_EDITION_PREFIX + "="
View Source
const OPWIRE_REQUEST_PREFIX string = "OPWIRE_REQUEST"
View Source
const OPWIRE_REQUEST_PREFIX_PLUS string = OPWIRE_REQUEST_PREFIX + "="
View Source
const OPWIRE_SETTINGS_PREFIX string = "OPWIRE_SETTINGS"
View Source
const OPWIRE_SETTINGS_PREFIX_PLUS string = OPWIRE_SETTINGS_PREFIX + "="
Variables ¶
This section is empty.
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(descriptor *invokers.CommandDescriptor, names ...string) error
ResolveCommandDescriptor(opts *invokers.CommandInvocation) (descriptor *invokers.CommandDescriptor, resourceName *string, methodName *string, err error)
GetSettings(resourceName string) []string
StoreSettings(prefix string, settings map[string]interface{}, format string, resourceName string) error
Run(io.Reader, *invokers.CommandInvocation, io.Writer, io.Writer) (*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.