services

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

type AgentServerOptions interface {
	GetConfigPath() string
	GetDirectCommand() string
	GetHost() string
	GetPort() uint
	GetStaticPath() map[string]string
	SuppressAutoStart() bool
	GetRevision() string
	GetVersion() string
}

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 Map = map[string]interface{}

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

type ReqRestrictorOptions interface {
	ConcurrentLimitEnabled() bool
	ConcurrentLimitTotal() int
	SingleFlightEnabled() bool
	SingleFlightReqIdName() string
	SingleFlightByMethod() bool
	SingleFlightByPath() bool
	SingleFlightByBody() bool
	SingleFlightByHeaders() []string
	SingleFlightByQueries() []string
	SingleFlightByUserIP() bool
}

type ReqSerializer struct{}

type RequestPacket struct {
	Method *string           `json:"method"`
	Path   *string           `json:"path"`
	Header http.Header       `json:"header"`
	Query  url.Values        `json:"query"`
	Params map[string]string `json:"params"`
}

type SingleFlightPattern struct {
	ReqIdName  string
	HasMethod  bool
	HasPath    bool
	HasHeaders []string
	HasQueries []string
	HasBody    bool
	HasUserIP  bool
}

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

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

type TextFormatterOptions interface {
	GetFormat() string
}