Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetOriginalErr ¶
Types ¶
type Pool ¶
type Pool interface { // Workers returns worker list associated with the pool. Workers() (workers []*worker.Process) // Exec payload Exec(ctx context.Context, p *payload.Payload) (*payload.Payload, error) // Reset kill all workers inside the watcher and replaces with new Reset(ctx context.Context) error // Destroy all underlying stack (but let them complete the task). Destroy(ctx context.Context) }
type Proxy ¶
type Proxy struct {
// contains filtered or unexported fields
}
Proxy manages GRPC/RoadRunner bridge.
func (*Proxy) RegisterMethod ¶
RegisterMethod registers new RPC method.
func (*Proxy) ServiceDesc ¶
func (p *Proxy) ServiceDesc() *grpc.ServiceDesc
ServiceDesc returns service description for the proxy.
Click to show internal directories.
Click to hide internal directories.