daemon

Documentation

Index

• type AWSUsage
• type Client
  • func Dial(_ context.Context, sockPath string) (*Client, error)
  • func DialPath(_ context.Context, sockPath string, urlPath string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) GetCompilerIncludePath(in *GetCompilerIncludePathArgs) (*GetCompilerIncludePathReply, error)
  • func (c *Client) GetDaemonStats(in *StatsArgs) (*StatsReply, error)
  • func (c *Client) InvokeWithFiles(in *InvokeWithFilesArgs) (*InvokeWithFilesReply, error)
  • func (c *Client) Ping(in *PingArgs) (*PingReply, error)
  • func (c *Client) Shutdown(in *ShutdownArgs) (*ShutdownReply, error)
  • func (c *Client) TraceSpans(in *TraceSpansArgs) (*TraceSpansReply, error)
• type GetCompilerIncludePathArgs
• type GetCompilerIncludePathReply
• type InvokeWithFilesArgs
• type InvokeWithFilesReply
• type PingArgs
• type PingReply
• type ShutdownArgs
• type ShutdownReply
• type Stats
• type StatsArgs
• type StatsReply
• type Timing
• type TraceSpansArgs
• type TraceSpansReply

Types

type AWSUsage

type AWSUsage struct {
	Lambda   protocol.LambdaUsage
	LocalS3  protocol.StoreUsage
	RemoteS3 protocol.StoreUsage
}

type Client

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

func Dial

func Dial(_ context.Context, sockPath string) (*Client, error)

func DialPath

func DialPath(_ context.Context, sockPath string, urlPath string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) GetCompilerIncludePath

func (c *Client) GetCompilerIncludePath(in *GetCompilerIncludePathArgs) (*GetCompilerIncludePathReply, error)

func (*Client) GetDaemonStats

func (c *Client) GetDaemonStats(in *StatsArgs) (*StatsReply, error)

func (*Client) InvokeWithFiles

func (c *Client) InvokeWithFiles(in *InvokeWithFilesArgs) (*InvokeWithFilesReply, error)

func (*Client) Ping

func (c *Client) Ping(in *PingArgs) (*PingReply, error)

func (*Client) Shutdown

func (c *Client) Shutdown(in *ShutdownArgs) (*ShutdownReply, error)

func (*Client) TraceSpans

func (c *Client) TraceSpans(in *TraceSpansArgs) (*TraceSpansReply, error)

type GetCompilerIncludePathArgs

type GetCompilerIncludePathArgs struct {
	Compiler string
	Language string
}

type GetCompilerIncludePathReply

type GetCompilerIncludePathReply struct {
	Paths []string
}

type InvokeWithFilesArgs

type InvokeWithFilesArgs struct {
	Trace      *tracing.Propagation
	Function   string
	ReturnLogs bool
	Args       []string
	Stdin      []byte
	Files      files.List
	Outputs    files.List

	// If true, release the llamacc semaphore to allow other
	// llamacc processes to use CPU while we talk to AWS
	DropSemaphore bool
}

type InvokeWithFilesReply

type InvokeWithFilesReply struct {
	InvokeErr  string
	ExitStatus int
	Stdout     []byte
	Stderr     []byte
	Logs       []byte

	Timing Timing
}

type PingArgs

type PingArgs struct{}

type PingReply

type PingReply struct {
	ServerPid int
}

type ShutdownArgs

type ShutdownArgs struct{}

type ShutdownReply

type ShutdownReply struct{}

type Stats

type Stats struct {
	InFlight    uint64
	MaxInFlight uint64

	Invocations    uint64
	FunctionErrors uint64
	OtherErrors    uint64
	ExitStatuses   [256]uint64

	Usage AWSUsage
}

type StatsArgs

type StatsArgs struct {
	Reset bool
}

type StatsReply

type StatsReply struct {
	Stats Stats
}

type Timing

type Timing struct {
	E2E    time.Duration
	Upload time.Duration
	Fetch  time.Duration
	Remote protocol.Timing
	Invoke time.Duration
}

type TraceSpansArgs

type TraceSpansArgs struct {
	Spans []tracing.Span
}

type TraceSpansReply

type TraceSpansReply struct{}