Documentation
¶
Index ¶
- type ContextAwareMutex
- type InterpreterTicket
- type MultiInterpreterRuntime
- func (r *MultiInterpreterRuntime) Acquire(ctx context.Context) (*InterpreterTicket, error)
- func (r *MultiInterpreterRuntime) Apply(token *InterpreterTicket, _ context.Context, f func() error) error
- func (r *MultiInterpreterRuntime) Map(ctx context.Context, f func(t *InterpreterTicket) error) error
- func (r *MultiInterpreterRuntime) Release(token *InterpreterTicket) error
- func (r *MultiInterpreterRuntime) Start(ctx context.Context) error
- func (r *MultiInterpreterRuntime) Stop(ctx context.Context) error
- type Runtime
- type SingleInterpreterRuntime
- func (r *SingleInterpreterRuntime) Acquire(ctx context.Context) (*InterpreterTicket, error)
- func (r *SingleInterpreterRuntime) Apply(ticket *InterpreterTicket, _ context.Context, f func() error) error
- func (r *SingleInterpreterRuntime) Map(ctx context.Context, f func(token *InterpreterTicket) error) error
- func (r *SingleInterpreterRuntime) Release(ticket *InterpreterTicket) error
- func (r *SingleInterpreterRuntime) Start(ctx context.Context) error
- func (r *SingleInterpreterRuntime) Stop(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContextAwareMutex ¶
type ContextAwareMutex struct {
// contains filtered or unexported fields
}
func NewContextAwareMutex ¶
func NewContextAwareMutex() *ContextAwareMutex
func (*ContextAwareMutex) AssertLocked ¶
func (c *ContextAwareMutex) AssertLocked()
func (*ContextAwareMutex) Lock ¶
func (c *ContextAwareMutex) Lock() error
func (*ContextAwareMutex) LockWithContext ¶
func (c *ContextAwareMutex) LockWithContext(ctx context.Context) error
func (*ContextAwareMutex) Unlock ¶
func (c *ContextAwareMutex) Unlock()
type InterpreterTicket ¶
type InterpreterTicket struct {
// contains filtered or unexported fields
}
func (*InterpreterTicket) Id ¶
func (i *InterpreterTicket) Id() int64
type MultiInterpreterRuntime ¶
type MultiInterpreterRuntime struct {
// contains filtered or unexported fields
}
MultiInterpreterRuntime creates and manages multiple Python sub-interpreters.
func (*MultiInterpreterRuntime) Acquire ¶
func (r *MultiInterpreterRuntime) Acquire(ctx context.Context) (*InterpreterTicket, error)
func (*MultiInterpreterRuntime) Apply ¶
func (r *MultiInterpreterRuntime) Apply(token *InterpreterTicket, _ context.Context, f func() error) error
func (*MultiInterpreterRuntime) Map ¶
func (r *MultiInterpreterRuntime) Map(ctx context.Context, f func(t *InterpreterTicket) error) error
Map a function fn over all the interpreters, one at a time. Useful for initializing all interpreters to a given state.
func (*MultiInterpreterRuntime) Release ¶
func (r *MultiInterpreterRuntime) Release(token *InterpreterTicket) error
type Runtime ¶
type Runtime interface {
// Start the Python runtime.
Start(ctx context.Context) error
// Stop the Python runtime, removing all interpreter state.
Stop(ctx context.Context) error
// Acquire ownership of an interpreter until Release is called.
Acquire(ctx context.Context) (token *InterpreterTicket, err error)
// Release ownership of an interpreter identified by the given
// InterpreterTicket.
Release(token *InterpreterTicket) error
// Apply a function f over the interpreter described by the given
// InterpreterTicket.
Apply(token *InterpreterTicket, ctx context.Context, f func() error) error
// Map a function f over the interpreter or interpreters.
// In the case of multiple interpreters, an error aborts mapping over the
// rest.
Map(ctx context.Context, f func(token *InterpreterTicket) error) error
}
type SingleInterpreterRuntime ¶
type SingleInterpreterRuntime struct {
// contains filtered or unexported fields
}
func NewSingleInterpreterRuntime ¶
func NewSingleInterpreterRuntime(exe string, logger *service.Logger) (*SingleInterpreterRuntime, error)
func (*SingleInterpreterRuntime) Acquire ¶
func (r *SingleInterpreterRuntime) Acquire(ctx context.Context) (*InterpreterTicket, error)
func (*SingleInterpreterRuntime) Apply ¶
func (r *SingleInterpreterRuntime) Apply(ticket *InterpreterTicket, _ context.Context, f func() error) error
func (*SingleInterpreterRuntime) Map ¶
func (r *SingleInterpreterRuntime) Map(ctx context.Context, f func(token *InterpreterTicket) error) error
func (*SingleInterpreterRuntime) Release ¶
func (r *SingleInterpreterRuntime) Release(ticket *InterpreterTicket) error
Source Files
Click to show internal directories.
Click to hide internal directories.