Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AgentCreator ¶
type AgentRequest ¶
type AllPoolMembersFailedError ¶
type AllPoolMembersFailedError struct {
PoolName string
MemberNames string
Errors []AttemptError
Err error
}
func (*AllPoolMembersFailedError) Error ¶
func (e *AllPoolMembersFailedError) Error() string
func (*AllPoolMembersFailedError) Unwrap ¶
func (e *AllPoolMembersFailedError) Unwrap() error
type AttemptError ¶
type MemberConfig ¶
type MemberConfig struct {
Name string
Cfg agentconfig.Config
}
type PoolAgent ¶
func NewPoolAgent ¶
func NewPoolAgent(ctx context.Context, poolName string, members []MemberConfig, req AgentRequest, agentCreator AgentCreator) (*PoolAgent, error)
type PoolExecutor ¶
type PoolExecutor struct {
// contains filtered or unexported fields
}
func NewPoolExecutor ¶
func NewPoolExecutor(poolName string, members []MemberConfig, agentCreator AgentCreator, req AgentRequest) *PoolExecutor
func (*PoolExecutor) Close ¶
func (p *PoolExecutor) Close() error
Click to show internal directories.
Click to hide internal directories.