grpc

package
v1.1.4 Latest Latest
Warning

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

 Go to latest Published: Jan 1, 2024 License: MIT Imports: 32 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewAPIServiceServer 

func NewAPIServiceServer(
	svc *apiserver.Service,
	avatarBaseURL domain.AvatarBaseURL,
) pbconnect.APIServiceHandler

func NewBuildpackHelperService added in v1.1.0 

func NewBuildpackHelperService() pbconnect.BuildpackHelperServiceHandler

func NewBuildpackHelperServiceClient added in v1.1.0 

func NewBuildpackHelperServiceClient(
	address string,
) domain.BuildpackHelperServiceClient

func NewControllerBuilderService 

func NewControllerBuilderService(
	logStream *logstream.Service,
	privateKey domain.PrivateKey,
	imageConfig builder.ImageConfig,
	storage domain.Storage,
	appRepo domain.ApplicationRepository,
	artifactRepo domain.ArtifactRepository,
	buildRepo domain.BuildRepository,
	envRepo domain.EnvironmentRepository,
	gitRepo domain.GitRepositoryRepository,
) domain.ControllerBuilderService

func NewControllerBuilderServiceClient 

func NewControllerBuilderServiceClient(
	c ControllerServiceClientConfig,
	priority int,
	auth *TokenAuthInterceptor,
) domain.ControllerBuilderServiceClient

func NewControllerGiteaIntegrationService added in v0.22.0 

func NewControllerGiteaIntegrationService() domain.ControllerGiteaIntegrationService

func NewControllerGiteaIntegrationServiceClient added in v0.22.0 

func NewControllerGiteaIntegrationServiceClient(
	c ControllerServiceClientConfig,
) domain.ControllerGiteaIntegrationServiceClient

func NewControllerSSGenService 

func NewControllerSSGenService() domain.ControllerSSGenService

func NewControllerSSGenServiceClient 

func NewControllerSSGenServiceClient(
	c ControllerServiceClientConfig,
) domain.ControllerSSGenServiceClient

func NewControllerService 

func NewControllerService(
	backend domain.Backend,
	appRepo domain.ApplicationRepository,
	fetcher repofetcher.Service,
	cd cdservice.Service,
	builder domain.ControllerBuilderService,
	logStream *logstream.Service,
	pubKey *ssh.PublicKeys,
	sshConf domain.SSHConfig,
	adminerURL domain.AdminerURL,
) pbconnect.ControllerServiceHandler

func NewControllerServiceClient 

func NewControllerServiceClient(
	c ControllerServiceClientConfig,
) domain.ControllerServiceClient

Types

type APIService 

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

func (*APIService) CancelBuild 

func (s *APIService) CancelBuild(ctx context.Context, req *connect.Request[pb.BuildIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) CreateApplication 

func (s *APIService) CreateApplication(ctx context.Context, req *connect.Request[pb.CreateApplicationRequest]) (*connect.Response[pb.Application], error)

func (*APIService) CreateRepository 

func (s *APIService) CreateRepository(ctx context.Context, req *connect.Request[pb.CreateRepositoryRequest]) (*connect.Response[pb.Repository], error)

func (*APIService) CreateUserKey 

func (s *APIService) CreateUserKey(ctx context.Context, c *connect.Request[pb.CreateUserKeyRequest]) (*connect.Response[pb.UserKey], error)

func (*APIService) DeleteApplication 

func (s *APIService) DeleteApplication(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) DeleteEnvVar added in v0.7.3 

func (s *APIService) DeleteEnvVar(ctx context.Context, req *connect.Request[pb.DeleteApplicationEnvVarRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) DeleteRepository 

func (s *APIService) DeleteRepository(ctx context.Context, req *connect.Request[pb.RepositoryIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) DeleteUserKey 

func (s *APIService) DeleteUserKey(ctx context.Context, c *connect.Request[pb.DeleteUserKeyRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) GenerateKeyPair added in v0.6.0 

func (s *APIService) GenerateKeyPair(ctx context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.GenerateKeyPairResponse], error)

func (*APIService) GetAllBuilds added in v0.13.0 

func (s *APIService) GetAllBuilds(ctx context.Context, c *connect.Request[pb.GetAllBuildsRequest]) (*connect.Response[pb.GetBuildsResponse], error)

func (*APIService) GetApplication 

func (s *APIService) GetApplication(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[pb.Application], error)

func (*APIService) GetApplicationMetrics added in v0.15.0 

func (s *APIService) GetApplicationMetrics(ctx context.Context, req *connect.Request[pb.GetApplicationMetricsRequest]) (*connect.Response[pb.ApplicationMetrics], error)

func (*APIService) GetApplications 

func (s *APIService) GetApplications(ctx context.Context, req *connect.Request[pb.GetApplicationsRequest]) (*connect.Response[pb.GetApplicationsResponse], error)

func (*APIService) GetAvailableMetrics added in v0.15.0 

func (s *APIService) GetAvailableMetrics(ctx context.Context, c *connect.Request[emptypb.Empty]) (*connect.Response[pb.AvailableMetrics], error)

func (*APIService) GetBuild 

func (s *APIService) GetBuild(ctx context.Context, req *connect.Request[pb.BuildIdRequest]) (*connect.Response[pb.Build], error)

func (*APIService) GetBuildArtifact 

func (s *APIService) GetBuildArtifact(ctx context.Context, req *connect.Request[pb.ArtifactIdRequest]) (*connect.Response[pb.ArtifactContent], error)

func (*APIService) GetBuildLog 

func (s *APIService) GetBuildLog(ctx context.Context, req *connect.Request[pb.BuildIdRequest]) (*connect.Response[pb.BuildLog], error)

func (*APIService) GetBuildLogStream 

func (s *APIService) GetBuildLogStream(ctx context.Context, req *connect.Request[pb.BuildIdRequest], st *connect.ServerStream[pb.BuildLog]) error

func (*APIService) GetBuilds 

func (s *APIService) GetBuilds(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[pb.GetBuildsResponse], error)

func (*APIService) GetEnvVars 

func (s *APIService) GetEnvVars(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[pb.ApplicationEnvVars], error)

func (*APIService) GetMe 

func (s *APIService) GetMe(ctx context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.User], error)

func (*APIService) GetOutput 

func (s *APIService) GetOutput(ctx context.Context, req *connect.Request[pb.GetOutputRequest]) (*connect.Response[pb.ApplicationOutputs], error)

func (*APIService) GetOutputStream 

func (s *APIService) GetOutputStream(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest], st *connect.ServerStream[pb.ApplicationOutput]) error

func (*APIService) GetRepositories 

func (s *APIService) GetRepositories(ctx context.Context, req *connect.Request[pb.GetRepositoriesRequest]) (*connect.Response[pb.GetRepositoriesResponse], error)

func (*APIService) GetRepository 

func (s *APIService) GetRepository(ctx context.Context, req *connect.Request[pb.RepositoryIdRequest]) (*connect.Response[pb.Repository], error)

func (*APIService) GetRepositoryRefs added in v0.13.0 

func (s *APIService) GetRepositoryRefs(ctx context.Context, req *connect.Request[pb.RepositoryIdRequest]) (*connect.Response[pb.GetRepositoryRefsResponse], error)

func (*APIService) GetSystemInfo added in v0.10.1 

func (s *APIService) GetSystemInfo(ctx context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.SystemInfo], error)

func (*APIService) GetUserKeys 

func (s *APIService) GetUserKeys(ctx context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetUserKeysResponse], error)

func (*APIService) GetUsers added in v0.4.6 

func (s *APIService) GetUsers(ctx context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetUsersResponse], error)

func (*APIService) RefreshRepository 

func (s *APIService) RefreshRepository(ctx context.Context, req *connect.Request[pb.RepositoryIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) RetryCommitBuild 

func (s *APIService) RetryCommitBuild(ctx context.Context, req *connect.Request[pb.RetryCommitBuildRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) SetEnvVar 

func (s *APIService) SetEnvVar(ctx context.Context, req *connect.Request[pb.SetApplicationEnvVarRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) StartApplication 

func (s *APIService) StartApplication(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) StopApplication 

func (s *APIService) StopApplication(ctx context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) UpdateApplication 

func (s *APIService) UpdateApplication(ctx context.Context, req *connect.Request[pb.UpdateApplicationRequest]) (*connect.Response[emptypb.Empty], error)

func (*APIService) UpdateRepository 

func (s *APIService) UpdateRepository(ctx context.Context, req *connect.Request[pb.UpdateRepositoryRequest]) (*connect.Response[emptypb.Empty], error)

type AuthHeader 

type AuthHeader string

type AuthInterceptor 

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

func NewAuthInterceptor 

func NewAuthInterceptor(
	userRepo domain.UserRepository,
	header AuthHeader,
) *AuthInterceptor

func (*AuthInterceptor) WrapStreamingClient 

func (a *AuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

func (*AuthInterceptor) WrapStreamingHandler 

func (a *AuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

func (*AuthInterceptor) WrapUnary 

func (a *AuthInterceptor) WrapUnary(unaryFunc connect.UnaryFunc) connect.UnaryFunc

type BuildpackHelperService added in v1.1.0 

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

func (*BuildpackHelperService) CopyFileTree added in v1.1.0 

func (b *BuildpackHelperService) CopyFileTree(_ context.Context, req *connect.Request[pb.CopyFileTreeRequest]) (*connect.Response[emptypb.Empty], error)

func (*BuildpackHelperService) Exec added in v1.1.0 

func (b *BuildpackHelperService) Exec(ctx context.Context, req *connect.Request[pb.HelperExecRequest], st *connect.ServerStream[pb.HelperExecResponse]) error

type BuildpackHelperServiceClient added in v1.1.0 

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

func (*BuildpackHelperServiceClient) CopyFileTree added in v1.1.0 

func (b *BuildpackHelperServiceClient) CopyFileTree(ctx context.Context, destination string, tarStream io.Reader) error

func (*BuildpackHelperServiceClient) Exec added in v1.1.0 

func (b *BuildpackHelperServiceClient) Exec(ctx context.Context, workDir string, cmd []string, envs map[string]string, logWriter io.Writer) (int, error)

type CacheInterceptor added in v1.0.1 

type CacheInterceptor struct{}

func NewCacheInterceptor added in v1.0.1 

func NewCacheInterceptor() *CacheInterceptor

func (*CacheInterceptor) WrapStreamingClient added in v1.0.1 

func (c *CacheInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

func (*CacheInterceptor) WrapStreamingHandler added in v1.0.1 

func (c *CacheInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

func (*CacheInterceptor) WrapUnary added in v1.0.1 

func (c *CacheInterceptor) WrapUnary(unaryFunc connect.UnaryFunc) connect.UnaryFunc

type ControllerBuilderService 

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

func (*ControllerBuilderService) CancelBuild added in v0.20.0 

func (s *ControllerBuilderService) CancelBuild(buildID string)

func (*ControllerBuilderService) ConnectBuilder 

func (s *ControllerBuilderService) ConnectBuilder(ctx context.Context, st *connect.BidiStream[pb.BuilderResponse, pb.BuilderRequest]) error

func (*ControllerBuilderService) GetBuilderSystemInfo added in v1.1.0 

func (s *ControllerBuilderService) GetBuilderSystemInfo(_ context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.BuilderSystemInfo], error)

func (*ControllerBuilderService) ListenBuildSettled 

func (s *ControllerBuilderService) ListenBuildSettled() (sub <-chan struct{}, unsub func())

func (*ControllerBuilderService) ListenBuilderIdle 

func (s *ControllerBuilderService) ListenBuilderIdle() (sub <-chan struct{}, unsub func())

func (*ControllerBuilderService) PingBuild added in v1.1.0 

func (s *ControllerBuilderService) PingBuild(ctx context.Context, req *connect.Request[pb.BuildIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*ControllerBuilderService) SaveArtifact added in v1.1.0 

func (s *ControllerBuilderService) SaveArtifact(ctx context.Context, req *connect.Request[pb.SaveArtifactRequest]) (*connect.Response[emptypb.Empty], error)

func (*ControllerBuilderService) SaveBuildLog added in v1.1.0 

func (s *ControllerBuilderService) SaveBuildLog(_ context.Context, req *connect.Request[pb.SaveBuildLogRequest]) (*connect.Response[emptypb.Empty], error)

func (*ControllerBuilderService) StartBuilds added in v0.4.10 

func (s *ControllerBuilderService) StartBuilds(ctx context.Context, buildIDs []string)

func (*ControllerBuilderService) StreamBuildLog added in v1.1.0 

func (s *ControllerBuilderService) StreamBuildLog(_ context.Context, st *connect.ClientStream[pb.BuildLogPortion]) (*connect.Response[emptypb.Empty], error)

type ControllerBuilderServiceClient 

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

func (*ControllerBuilderServiceClient) ConnectBuilder 

func (c *ControllerBuilderServiceClient) ConnectBuilder(ctx context.Context, onRequest func(req *pb.BuilderRequest), response <-chan *pb.BuilderResponse) error

func (*ControllerBuilderServiceClient) GetBuilderSystemInfo added in v1.1.0 

func (c *ControllerBuilderServiceClient) GetBuilderSystemInfo(ctx context.Context) (*domain.BuilderSystemInfo, error)

func (*ControllerBuilderServiceClient) PingBuild added in v1.1.0 

func (c *ControllerBuilderServiceClient) PingBuild(ctx context.Context, buildID string) error

func (*ControllerBuilderServiceClient) SaveArtifact added in v1.1.0 

func (c *ControllerBuilderServiceClient) SaveArtifact(ctx context.Context, artifact *domain.Artifact, body []byte) error

func (*ControllerBuilderServiceClient) SaveBuildLog added in v1.1.0 

func (c *ControllerBuilderServiceClient) SaveBuildLog(ctx context.Context, buildID string, body []byte) error

func (*ControllerBuilderServiceClient) StreamBuildLog added in v1.1.0 

func (c *ControllerBuilderServiceClient) StreamBuildLog(ctx context.Context, buildID string, send <-chan []byte) error

type ControllerGiteaIntegrationService added in v0.22.0 

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

func (*ControllerGiteaIntegrationService) Broadcast added in v0.22.0 

func (s *ControllerGiteaIntegrationService) Broadcast(req *pb.GiteaIntegrationRequest)

func (*ControllerGiteaIntegrationService) Connect added in v0.22.0 

func (s *ControllerGiteaIntegrationService) Connect(ctx context.Context, _ *connect.Request[emptypb.Empty], st *connect.ServerStream[pb.GiteaIntegrationRequest]) error

type ControllerGiteaIntegrationServiceClient added in v0.22.0 

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

func (*ControllerGiteaIntegrationServiceClient) Connect added in v0.22.0 

func (c *ControllerGiteaIntegrationServiceClient) Connect(ctx context.Context, onRequest func(req *pb.GiteaIntegrationRequest)) error

type ControllerSSGenService 

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

func (*ControllerSSGenService) BroadcastSSGen 

func (s *ControllerSSGenService) BroadcastSSGen(req *pb.SSGenRequest)

func (*ControllerSSGenService) ConnectSSGen 

func (s *ControllerSSGenService) ConnectSSGen(ctx context.Context, _ *connect.Request[emptypb.Empty], st *connect.ServerStream[pb.SSGenRequest]) error

type ControllerSSGenServiceClient 

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

func (*ControllerSSGenServiceClient) ConnectSSGen 

func (c *ControllerSSGenServiceClient) ConnectSSGen(ctx context.Context, onRequest func(req *pb.SSGenRequest)) error

type ControllerService 

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

func (*ControllerService) CancelBuild 

func (s *ControllerService) CancelBuild(_ context.Context, c *connect.Request[pb.BuildIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*ControllerService) FetchRepository 

func (s *ControllerService) FetchRepository(_ context.Context, c *connect.Request[pb.RepositoryIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*ControllerService) GetSystemInfo added in v0.10.1 

func (s *ControllerService) GetSystemInfo(_ context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.SystemInfo], error)

func (*ControllerService) RegisterBuild added in v0.9.0 

func (s *ControllerService) RegisterBuild(_ context.Context, req *connect.Request[pb.ApplicationIdRequest]) (*connect.Response[emptypb.Empty], error)

func (*ControllerService) StreamBuildLog 

func (s *ControllerService) StreamBuildLog(ctx context.Context, c *connect.Request[pb.BuildIdRequest], c2 *connect.ServerStream[pb.BuildLog]) error

func (*ControllerService) SyncDeployments 

func (s *ControllerService) SyncDeployments(_ context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[emptypb.Empty], error)

type ControllerServiceClient 

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

func (*ControllerServiceClient) CancelBuild 

func (c *ControllerServiceClient) CancelBuild(ctx context.Context, buildID string) error

func (*ControllerServiceClient) FetchRepository 

func (c *ControllerServiceClient) FetchRepository(ctx context.Context, repositoryID string) error

func (*ControllerServiceClient) GetSystemInfo added in v0.10.1 

func (c *ControllerServiceClient) GetSystemInfo(ctx context.Context) (*domain.SystemInfo, error)

func (*ControllerServiceClient) RegisterBuild added in v0.9.0 

func (c *ControllerServiceClient) RegisterBuild(ctx context.Context, appID string) error

func (*ControllerServiceClient) StreamBuildLog 

func (c *ControllerServiceClient) StreamBuildLog(ctx context.Context, buildID string) (<-chan *pb.BuildLog, error)

func (*ControllerServiceClient) SyncDeployments 

func (c *ControllerServiceClient) SyncDeployments(ctx context.Context) error

type ControllerServiceClientConfig 

type ControllerServiceClientConfig struct {
	URL string `mapstructure:"url" yaml:"url"`
}

type TokenAuthInterceptor added in v1.1.0 

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

func NewTokenAuthInterceptor added in v1.1.0 

func NewTokenAuthInterceptor(
	header string,
	token string,
) (*TokenAuthInterceptor, error)

func (*TokenAuthInterceptor) WrapStreamingClient added in v1.1.0 

func (a *TokenAuthInterceptor) WrapStreamingClient(next connect.StreamingClientFunc) connect.StreamingClientFunc

func (*TokenAuthInterceptor) WrapStreamingHandler added in v1.1.0 

func (a *TokenAuthInterceptor) WrapStreamingHandler(next connect.StreamingHandlerFunc) connect.StreamingHandlerFunc

func (*TokenAuthInterceptor) WrapUnary added in v1.1.0 

func (a *TokenAuthInterceptor) WrapUnary(unaryFunc connect.UnaryFunc) connect.UnaryFunc

Source Files

View all Source files

Directories

Path Synopsis
pb
pbconnect

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.