gcp

package
v0.0.0-...-3a59d39 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2026 License: MIT Imports: 36 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefangCDProjectName            = "defang-cd"
	DefangUploadServiceAccountName = "defang-upload"
	UploadPrefix                   = "uploads/"
)

Variables

View Source 
var (
	DefaultCDTags = map[string]string{"created-by": "defang"}
)

Functions

func GetGoogleAPIErrorDetail 

func GetGoogleAPIErrorDetail(detail any, path string) string

Used to get nested values from the detail of a googleapi.Error

func GetListInStruct 

func GetListInStruct(s *structpb.Struct, path string) []*structpb.Value

func GetUserEmail 

func GetUserEmail() (string, error)

func GetValueInStruct 

func GetValueInStruct(s *structpb.Struct, path string) string

Extract a string value from a nested structpb.Struct

func LogEntriesToString 

func LogEntriesToString(logEntries []*loggingpb.LogEntry) string

func LogEntryToString 

func LogEntryToString(logEntry *loggingpb.LogEntry) (string, string, error)

Types

type ByocGcp 

type ByocGcp struct {
	*byoc.ByocBaseClient
	// contains filtered or unexported fields
}

func NewByocProvider 

func NewByocProvider(ctx context.Context, tenantName types.TenantLabel, stack string) *ByocGcp

func (*ByocGcp) AccountInfo 

func (b *ByocGcp) AccountInfo(ctx context.Context) (*client.AccountInfo, error)

func (*ByocGcp) CdCommand 

func (b *ByocGcp) CdCommand(ctx context.Context, req client.CdCommandRequest) (types.ETag, error)

func (*ByocGcp) CdList 

func (b *ByocGcp) CdList(ctx context.Context, _allRegions bool) (iter.Seq[string], error)

func (*ByocGcp) CreateUploadURL 

func (b *ByocGcp) CreateUploadURL(ctx context.Context, req *defangv1.UploadURLRequest) (*defangv1.UploadURLResponse, error)

func (*ByocGcp) DeleteConfig 

func (b *ByocGcp) DeleteConfig(ctx context.Context, req *defangv1.Secrets) error

func (*ByocGcp) Deploy 

func (b *ByocGcp) Deploy(ctx context.Context, req *client.DeployRequest) (*defangv1.DeployResponse, error)

func (*ByocGcp) GetDeploymentStatus 

func (b *ByocGcp) GetDeploymentStatus(ctx context.Context) error

func (*ByocGcp) GetPrivateDomain 

func (*ByocGcp) GetPrivateDomain(projectName string) string

func (*ByocGcp) GetProjectUpdate 

func (b *ByocGcp) GetProjectUpdate(ctx context.Context, projectName string) (*defangv1.ProjectUpdate, error)

func (*ByocGcp) GetService 

func (b *ByocGcp) GetService(ctx context.Context, req *defangv1.GetRequest) (*defangv1.ServiceInfo, error)

func (*ByocGcp) GetServices 

func (b *ByocGcp) GetServices(ctx context.Context, req *defangv1.GetServicesRequest) (*defangv1.GetServicesResponse, error)

func (*ByocGcp) ListConfig 

func (b *ByocGcp) ListConfig(ctx context.Context, req *defangv1.ListConfigsRequest) (*defangv1.Secrets, error)

func (*ByocGcp) PrepareDomainDelegation 

func (b *ByocGcp) PrepareDomainDelegation(ctx context.Context, req client.PrepareDomainDelegationRequest) (*client.PrepareDomainDelegationResponse, error)

func (*ByocGcp) Preview 

func (b *ByocGcp) Preview(ctx context.Context, req *client.DeployRequest) (*defangv1.DeployResponse, error)

func (*ByocGcp) PutConfig 

func (b *ByocGcp) PutConfig(ctx context.Context, req *defangv1.PutConfigRequest) error

func (*ByocGcp) QueryLogs 

func (b *ByocGcp) QueryLogs(ctx context.Context, req *defangv1.TailRequest) (client.ServerStream[defangv1.TailResponse], error)

func (*ByocGcp) SetUpCD 

func (b *ByocGcp) SetUpCD(ctx context.Context) error

func (*ByocGcp) Subscribe 

func (b *ByocGcp) Subscribe(ctx context.Context, req *defangv1.SubscribeRequest) (client.ServerStream[defangv1.SubscribeResponse], error)

func (*ByocGcp) TearDownCD 

func (b *ByocGcp) TearDownCD(ctx context.Context) error

type CloudBuildStep 

type CloudBuildStep struct {
	Name       string   `yaml:"name,omitempty"`
	Entrypoint string   `yaml:"entrypoint,omitempty"`
	Args       []string `yaml:"args,omitempty"`
	Env        []string `yaml:"env,omitempty"`
}

type ConflictDelegateDomainError 

type ConflictDelegateDomainError struct {
	NewDomain      string
	ConflictDomain string
	ConflictZone   string
	Err            error
}

func (ConflictDelegateDomainError) Error 

func (e ConflictDelegateDomainError) Error() string

type CredentialsError 

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

func (CredentialsError) Unwrap 

func (e CredentialsError) Unwrap() error

type GcpLogsClient 

type GcpLogsClient interface {
	ListLogEntries(ctx context.Context, query string, order gcp.Order) (gcp.Lister, error)
	NewTailer(ctx context.Context) (gcp.Tailer, error)
	GetExecutionEnv(ctx context.Context, executionName string) (map[string]string, error)
	GetProjectID() gcp.ProjectId
	GetBuildInfo(ctx context.Context, buildId string) (*gcp.BuildTag, error)
}

type LogFilter 

type LogFilter[T any] func(entry T) T

type LogParser 

type LogParser[T any] func(*loggingpb.LogEntry) ([]*T, error)

type LogStream 

type LogStream struct {
	*ServerStream[defangv1.TailResponse]
}

func NewLogStream 

func NewLogStream(ctx context.Context, gcpLogsClient GcpLogsClient, services []string) (*LogStream, error)

func (*LogStream) AddCloudBuildLog 

func (s *LogStream) AddCloudBuildLog(stack, project, etag string, services []string)

func (*LogStream) AddFilter 

func (s *LogStream) AddFilter(filter string)

func (*LogStream) AddJobExecutionLog 

func (s *LogStream) AddJobExecutionLog(executionName string)

func (*LogStream) AddJobLog 

func (s *LogStream) AddJobLog(stack, project, etag string, services []string)

func (*LogStream) AddServiceLog 

func (s *LogStream) AddServiceLog(stack, project, etag string, services []string)

func (*LogStream) AddSince 

func (s *LogStream) AddSince(start time.Time)

func (*LogStream) AddUntil 

func (s *LogStream) AddUntil(end time.Time)

type Query 

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

func NewLogQuery 

func NewLogQuery(projectId gcp.ProjectId) *Query

func NewQuery 

func NewQuery(baseQuery string) *Query

func NewSubscribeQuery 

func NewSubscribeQuery() *Query

func (*Query) AddCloudBuildActivityQuery 

func (q *Query) AddCloudBuildActivityQuery()

func (*Query) AddCloudBuildLogQuery 

func (q *Query) AddCloudBuildLogQuery(stack, project, etag string, services []string)

func (*Query) AddComputeEngineInstanceGroupAddInstances 

func (q *Query) AddComputeEngineInstanceGroupAddInstances()

func (*Query) AddComputeEngineInstanceGroupInsertOrPatch 

func (q *Query) AddComputeEngineInstanceGroupInsertOrPatch(stack, project, etag string, services []string)

func (*Query) AddComputeEngineLogQuery 

func (q *Query) AddComputeEngineLogQuery(stack, project, etag string, services []string)

func (*Query) AddFilter 

func (q *Query) AddFilter(filter string)

func (*Query) AddJobExecutionQuery 

func (q *Query) AddJobExecutionQuery(executionName string)

func (*Query) AddJobExecutionUpdateQuery 

func (q *Query) AddJobExecutionUpdateQuery(executionName string)

func (*Query) AddJobLogQuery 

func (q *Query) AddJobLogQuery(stack, project, etag string, services []string)

func (*Query) AddJobStatusUpdateRequestQuery 

func (q *Query) AddJobStatusUpdateRequestQuery(stack, project, etag string, services []string)

func (*Query) AddJobStatusUpdateResponseQuery 

func (q *Query) AddJobStatusUpdateResponseQuery(stack, project, etag string, services []string)

func (*Query) AddQuery 

func (q *Query) AddQuery(query string)

func (*Query) AddServiceLogQuery 

func (q *Query) AddServiceLogQuery(stack, project, etag string, services []string)

func (*Query) AddServiceStatusReponseUpdate 

func (q *Query) AddServiceStatusReponseUpdate(stack, project, etag string, services []string)

func (*Query) AddServiceStatusRequestUpdate 

func (q *Query) AddServiceStatusRequestUpdate(stack, project, etag string, services []string)

func (*Query) AddSince 

func (q *Query) AddSince(since time.Time)

func (*Query) AddUntil 

func (q *Query) AddUntil(until time.Time)

func (*Query) GetQuery 

func (q *Query) GetQuery() string

type ServerStream 

type ServerStream[T any] struct {
	// contains filtered or unexported fields
}

func NewServerStream 

func NewServerStream[T any](ctx context.Context, gcpLogsClient GcpLogsClient, parse LogParser[T], filters ...LogFilter[*T]) (*ServerStream[T], error)

func (*ServerStream[T]) AddCustomQuery 

func (s *ServerStream[T]) AddCustomQuery(query string)

func (*ServerStream[T]) Close 

func (s *ServerStream[T]) Close() error

func (*ServerStream[T]) Err 

func (s *ServerStream[T]) Err() error

func (*ServerStream[T]) GetQuery 

func (s *ServerStream[T]) GetQuery() string

func (*ServerStream[T]) Msg 

func (s *ServerStream[T]) Msg() *T

func (*ServerStream[T]) Receive 

func (s *ServerStream[T]) Receive() bool

func (*ServerStream[T]) StartFollow 

func (s *ServerStream[T]) StartFollow(start time.Time)

func (*ServerStream[T]) StartHead 

func (s *ServerStream[T]) StartHead(limit int32)

func (*ServerStream[T]) StartTail 

func (s *ServerStream[T]) StartTail(limit int32)

type SubscribeStream 

type SubscribeStream struct {
	*ServerStream[defangv1.SubscribeResponse]
}

func NewSubscribeStream 

func NewSubscribeStream(ctx context.Context, driver GcpLogsClient, waitForCD bool, etag string, services []string, filters ...LogFilter[*defangv1.SubscribeResponse]) (*SubscribeStream, error)

func (*SubscribeStream) AddJobExecutionUpdate 

func (s *SubscribeStream) AddJobExecutionUpdate(executionName string)

func (*SubscribeStream) AddJobStatusUpdate 

func (s *SubscribeStream) AddJobStatusUpdate(stack, project, etag string, services []string)

func (*SubscribeStream) AddServiceStatusUpdate 

func (s *SubscribeStream) AddServiceStatusUpdate(stack, project, etag string, services []string)

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.