grpc

package
v1.10.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 11, 2024 License: MPL-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func New added in v1.10.0 

func New(
	conf *config.Config,
	logger *zap.Logger,
	auth *AuthServer,
	workspaces *WorkspaceServer,
	plans *PlanServer,
	logs *LogsServer,
	runs *RunServer,
	otelInterceptor *otelconnect.Interceptor,
	authInterceptor *auth.Interceptor,
	lc fx.Lifecycle,
) *http.ServeMux

Types

type AuthServer added in v1.7.0 

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

func NewAuthServer added in v1.7.0 

func NewAuthServer(conf *config.Config) *AuthServer

func (*AuthServer) GenerateRunnerToken added in v1.7.0 

func (a *AuthServer) GenerateRunnerToken(
	ctx context.Context,
	req *connect.Request[v1.GenerateRunnerTokenRequest],
) (*connect.Response[v1.GenerateRunnerTokenResponse], error)

type LogsServer added in v1.7.0 

type LogsServer struct {
	Runs        run.RunRepository
	FileManager file_manager.FileManager
}

func (*LogsServer) StreamLogs added in v1.7.0 

func (ls *LogsServer) StreamLogs(ctx context.Context, req *connect.Request[v1.StreamLogsRequest]) (*connect.Response[v1.StreamLogsResponse], error)

func (*LogsServer) UploadLogs added in v1.7.0 

func (ls *LogsServer) UploadLogs(ctx context.Context, req *connect.Request[v1.UploadLogsRequest]) (*connect.Response[v1.UploadLogsResponse], error)

type PlanServer added in v1.7.0 

type PlanServer struct {
	Runs        run.RunRepository
	FileManager file_manager.FileManager
}

func (*PlanServer) UploadPlan added in v1.7.0 

func (ps *PlanServer) UploadPlan(
	ctx context.Context,
	req *connect.Request[v1.UploadPlanRequest],
) (*connect.Response[v1.UploadPlanResponse], error)

type RunServer 

type RunServer struct {
	AgentRepository agent.AgentRepository
	RunRepository   run.RunRepository
}

func (*RunServer) Get added in v1.7.0 

func (s *RunServer) Get(
	ctx context.Context,
	req *connect.Request[v1.GetRunRequest],
) (*connect.Response[v1.Run], error)

func (*RunServer) List 

func (s *RunServer) List(
	ctx context.Context, req *connect.Request[v1.ListRunsRequest],
) (*connect.Response[v1.ListRunsResponse], error)

func (*RunServer) Update 

func (s *RunServer) Update(
	ctx context.Context, req *connect.Request[v1.UpdateRunRequest],
) (*connect.Response[v1.Run], error)

func (*RunServer) Watch 

func (s *RunServer) Watch(
	ctx context.Context,
	req *connect.Request[v1.WatchRunsRequest],
	stream *connect.ServerStream[v1.Run],
) error

type WorkspaceServer added in v1.7.0 

type WorkspaceServer struct {
	Repository    workspaces.WorkspacesRepository
	VcsRepository vcs_connection.Repository
}

func (*WorkspaceServer) GetVariables added in v1.7.0 

func (ws *WorkspaceServer) GetVariables(
	ctx context.Context,
	request *connect.Request[apiv1.GetVariablesRequest],
) (
	*connect.Response[apiv1.GetVariablesResponse],
	error,
)

func (*WorkspaceServer) GetVcsConnection added in v1.7.0 

func (ws *WorkspaceServer) GetVcsConnection(
	ctx context.Context,
	request *connect.Request[apiv1.GetVcsConnectionRequest],
) (
	*connect.Response[apiv1.GetVcsConnectionResponse],
	error,
)

func (*WorkspaceServer) GetWorkspace added in v1.7.0 

func (ws *WorkspaceServer) GetWorkspace(
	ctx context.Context,
	request *connect.Request[apiv1.GetWorkspaceRequest],
) (
	*connect.Response[apiv1.GetWorkspaceResponse],
	error,
)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.