langrungrpcsvc

Documentation

Index

• type LocalClient
  • func (c *LocalClient) CallFunction(ctx context.Context, in *pblangsvc.CallFunctionRequest, _ ...grpc.CallOption) (pblangsvc.LangRun_CallFunctionClient, error)
  • func (c *LocalClient) ListRuns(ctx context.Context, in *pblangsvc.ListRunsRequest, _ ...grpc.CallOption) (*pblangsvc.ListRunsResponse, error)
  • func (c *LocalClient) Run(ctx context.Context, in *pblangsvc.RunRequest, _ ...grpc.CallOption) (pblangsvc.LangRun_RunClient, error)
  • func (c *LocalClient) RunCallReturn(ctx context.Context, in *pblangsvc.RunCallReturnRequest, _ ...grpc.CallOption) (*pblangsvc.RunCallReturnResponse, error)
  • func (c *LocalClient) RunCancel(ctx context.Context, in *pblangsvc.RunCancelRequest, _ ...grpc.CallOption) (*pblangsvc.RunCancelResponse, error)
  • func (c *LocalClient) RunDiscard(ctx context.Context, in *pblangsvc.RunDiscardRequest, _ ...grpc.CallOption) (*pblangsvc.RunDiscardResponse, error)
  • func (c *LocalClient) RunGet(ctx context.Context, in *pblangsvc.RunGetRequest, _ ...grpc.CallOption) (*pblangsvc.RunGetResponse, error)
  • func (c *LocalClient) RunLoadReturn(ctx context.Context, in *pblangsvc.RunLoadReturnRequest, _ ...grpc.CallOption) (*pblangsvc.RunLoadReturnResponse, error)
• type Svc
  • func (s *Svc) CallFunction(req *pblangsvc.CallFunctionRequest, srv pblangsvc.LangRun_CallFunctionServer) error
  • func (s *Svc) ListRuns(ctx context.Context, req *pblangsvc.ListRunsRequest) (*pblangsvc.ListRunsResponse, error)
  • func (s *Svc) Register(ctx context.Context, srv *grpc.Server, gw *runtime.ServeMux)
  • func (s *Svc) Run(req *pblangsvc.RunRequest, srv pblangsvc.LangRun_RunServer) error
  • func (s *Svc) RunCallReturn(ctx context.Context, req *pblangsvc.RunCallReturnRequest) (*pblangsvc.RunCallReturnResponse, error)
  • func (s *Svc) RunCancel(ctx context.Context, req *pblangsvc.RunCancelRequest) (*pblangsvc.RunCancelResponse, error)
  • func (s *Svc) RunDiscard(ctx context.Context, req *pblangsvc.RunDiscardRequest) (*pblangsvc.RunDiscardResponse, error)
  • func (s *Svc) RunGet(ctx context.Context, req *pblangsvc.RunGetRequest) (*pblangsvc.RunGetResponse, error)
  • func (s *Svc) RunLoadReturn(ctx context.Context, req *pblangsvc.RunLoadReturnRequest) (*pblangsvc.RunLoadReturnResponse, error)

Types

type LocalClient

type LocalClient struct {
	Server pblangsvc.LangRunServer
}

func (*LocalClient) CallFunction

func (c *LocalClient) CallFunction(ctx context.Context, in *pblangsvc.CallFunctionRequest, _ ...grpc.CallOption) (pblangsvc.LangRun_CallFunctionClient, error)

func (*LocalClient) ListRuns

func (c *LocalClient) ListRuns(ctx context.Context, in *pblangsvc.ListRunsRequest, _ ...grpc.CallOption) (*pblangsvc.ListRunsResponse, error)

func (*LocalClient) Run

func (c *LocalClient) Run(ctx context.Context, in *pblangsvc.RunRequest, _ ...grpc.CallOption) (pblangsvc.LangRun_RunClient, error)

func (*LocalClient) RunCallReturn

func (c *LocalClient) RunCallReturn(ctx context.Context, in *pblangsvc.RunCallReturnRequest, _ ...grpc.CallOption) (*pblangsvc.RunCallReturnResponse, error)

func (*LocalClient) RunCancel

func (c *LocalClient) RunCancel(ctx context.Context, in *pblangsvc.RunCancelRequest, _ ...grpc.CallOption) (*pblangsvc.RunCancelResponse, error)

func (*LocalClient) RunDiscard

func (c *LocalClient) RunDiscard(ctx context.Context, in *pblangsvc.RunDiscardRequest, _ ...grpc.CallOption) (*pblangsvc.RunDiscardResponse, error)

func (*LocalClient) RunGet

func (c *LocalClient) RunGet(ctx context.Context, in *pblangsvc.RunGetRequest, _ ...grpc.CallOption) (*pblangsvc.RunGetResponse, error)

func (*LocalClient) RunLoadReturn

func (c *LocalClient) RunLoadReturn(ctx context.Context, in *pblangsvc.RunLoadReturnRequest, _ ...grpc.CallOption) (*pblangsvc.RunLoadReturnResponse, error)

type Svc

type Svc struct {
	pblangsvc.UnimplementedLangRunServer

	L    L.Nullable
	Runs langrun.Runs
}

func (*Svc) CallFunction

func (s *Svc) CallFunction(req *pblangsvc.CallFunctionRequest, srv pblangsvc.LangRun_CallFunctionServer) error

func (*Svc) ListRuns

func (s *Svc) ListRuns(ctx context.Context, req *pblangsvc.ListRunsRequest) (*pblangsvc.ListRunsResponse, error)

func (*Svc) Register

func (s *Svc) Register(ctx context.Context, srv *grpc.Server, gw *runtime.ServeMux)

func (*Svc) Run

func (s *Svc) Run(req *pblangsvc.RunRequest, srv pblangsvc.LangRun_RunServer) error

func (*Svc) RunCallReturn

func (s *Svc) RunCallReturn(ctx context.Context, req *pblangsvc.RunCallReturnRequest) (*pblangsvc.RunCallReturnResponse, error)

func (*Svc) RunCancel

func (s *Svc) RunCancel(ctx context.Context, req *pblangsvc.RunCancelRequest) (*pblangsvc.RunCancelResponse, error)

func (*Svc) RunDiscard

func (s *Svc) RunDiscard(ctx context.Context, req *pblangsvc.RunDiscardRequest) (*pblangsvc.RunDiscardResponse, error)

func (*Svc) RunGet

func (s *Svc) RunGet(ctx context.Context, req *pblangsvc.RunGetRequest) (*pblangsvc.RunGetResponse, error)

func (*Svc) RunLoadReturn

func (s *Svc) RunLoadReturn(ctx context.Context, req *pblangsvc.RunLoadReturnRequest) (*pblangsvc.RunLoadReturnResponse, error)