envelope

Documentation

Index

• type Child
• type Envelope
  • func NewEnvelope(ctx context.Context, aletArgs *protos.AkasaletArgs, config *protos.AppConfig, ...) (*Envelope, error)
  • func (e *Envelope) AkasaletAddress() string
  • func (e *Envelope) GetHealth(ctx context.Context) protos.HealthStatus
  • func (e *Envelope) Pid() (int, bool)
  • func (e *Envelope) Serve(h Handler) error
  • func (e *Envelope) UpdateComponents(components []string) error
  • func (e *Envelope) UpdateRoutingInfo(ctx context.Context, routing *protos.RoutingInfo) error
• type Handler
• type Options
• type ProcessChild
  • func (p *ProcessChild) Pid() (int, bool)
  • func (p *ProcessChild) Start(ctx context.Context, config *protos.AppConfig, args *protos.AkasaletArgs) error
  • func (p *ProcessChild) Stderr() io.ReadCloser
  • func (p *ProcessChild) Stdout() io.ReadCloser
  • func (p *ProcessChild) Wait() error

Types

type Child

type Child interface {
	// Start starts the child
	Start(context.Context, *protos.AppConfig, *protos.AkasaletArgs) error

	// Wait for the child to exit
	Wait() error

	// Stdout Different IO streams connection us to the child
	Stdout() io.ReadCloser
	Stderr() io.ReadCloser

	// Pid Identifier for child process, if available.
	Pid() (int, bool)
}

Child manages the child of an envelope. This is typically a child process, but tests may manage some in-process resources.

type Envelope

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

func NewEnvelope

func NewEnvelope(ctx context.Context, aletArgs *protos.AkasaletArgs, config *protos.AppConfig, options Options) (*Envelope, error)

func (*Envelope) AkasaletAddress

func (e *Envelope) AkasaletAddress() string

func (*Envelope) GetHealth

func (e *Envelope) GetHealth(ctx context.Context) protos.HealthStatus

func (*Envelope) Pid

func (e *Envelope) Pid() (int, bool)

func (*Envelope) Serve

func (e *Envelope) Serve(h Handler) error

func (*Envelope) UpdateComponents

func (e *Envelope) UpdateComponents(components []string) error

func (*Envelope) UpdateRoutingInfo

func (e *Envelope) UpdateRoutingInfo(ctx context.Context, routing *protos.RoutingInfo) error

type Handler

type Handler interface {
	ActivateComponent(ctx context.Context, req *protos.ActivateComponentRequest) (*protos.ActivateComponentReply, error)
	LogBatch(ctx context.Context, batch *protos.LogEntryBatch) error
}

type Options

type Options struct {
	TempDir string
	Logger  *slog.Logger
	Tracer  trace.Tracer
	Child   Child
}

type ProcessChild

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

func (*ProcessChild) Pid

func (p *ProcessChild) Pid() (int, bool)

func (*ProcessChild) Start

func (p *ProcessChild) Start(ctx context.Context, config *protos.AppConfig, args *protos.AkasaletArgs) error

func (*ProcessChild) Stderr

func (p *ProcessChild) Stderr() io.ReadCloser

func (*ProcessChild) Stdout

func (p *ProcessChild) Stdout() io.ReadCloser

func (*ProcessChild) Wait

func (p *ProcessChild) Wait() error