grpc

package
v1.5.4 Latest Latest
Warning

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

Go to latest
Published: Sep 2, 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 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

Types

type APIService

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

func (*APIService) CancelBuild

func (*APIService) CreateApplication

func (*APIService) CreateRepository

func (*APIService) CreateUserKey

func (*APIService) DeleteApplication

func (*APIService) DeleteEnvVar added in v0.7.3

func (*APIService) DeleteRepository

func (*APIService) DeleteUserKey

func (*APIService) GenerateKeyPair added in v0.6.0

func (*APIService) GetAllBuilds added in v0.13.0

func (*APIService) GetApplication

func (*APIService) GetApplicationMetrics added in v0.15.0

func (*APIService) GetAvailableMetrics added in v0.15.0

func (*APIService) GetBuild

func (*APIService) GetBuildArtifact

func (*APIService) GetBuildLog

func (*APIService) GetBuildLogStream

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

func (*APIService) GetMe

func (*APIService) GetRepository

func (*APIService) GetRepositoryCommits added in v1.3.0

func (*APIService) GetRepositoryRefs added in v0.13.0

func (*APIService) GetSystemInfo added in v0.10.1

func (*APIService) GetUserKeys

func (*APIService) GetUsers added in v0.4.6

func (*APIService) RefreshRepository

func (*APIService) RetryCommitBuild

func (*APIService) StartApplication

func (*APIService) StopApplication

func (*APIService) UpdateApplication

func (*APIService) UpdateRepository

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 (*AuthInterceptor) WrapStreamingHandler

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 (*BuildpackHelperService) Exec added in v1.1.0

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 (*CacheInterceptor) WrapStreamingHandler added in v1.0.1

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 (*ControllerBuilderService) GetBuilderSystemInfo added in v1.1.0

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 (*ControllerBuilderService) SaveArtifact added in v1.1.0

func (*ControllerBuilderService) SaveBuildLog added in v1.1.0

func (*ControllerBuilderService) SaveRuntimeImage added in v1.5.0

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

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 (*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) SaveRuntimeImage added in v1.5.0

func (c *ControllerBuilderServiceClient) SaveRuntimeImage(ctx context.Context, buildID string, size int64) 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 (*ControllerGiteaIntegrationService) Connect added in v0.22.0

type ControllerGiteaIntegrationServiceClient added in v0.22.0

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

func (*ControllerGiteaIntegrationServiceClient) Connect added in v0.22.0

type ControllerSSGenService

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

func (*ControllerSSGenService) BroadcastSSGen

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

func (*ControllerSSGenService) ConnectSSGen

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 (*ControllerService) FetchRepository

func (*ControllerService) GetSystemInfo added in v0.10.1

func (*ControllerService) RegisterBuild added in v0.9.0

func (*ControllerService) StreamBuildLog

func (*ControllerService) SyncDeployments

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 (*TokenAuthInterceptor) WrapStreamingHandler added in v1.1.0

func (*TokenAuthInterceptor) WrapUnary added in v1.1.0

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

Directories

Path Synopsis
pb

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL