grpc

Documentation

Index

• func GetConfigFromContext(ctx context.Context) any
• func Init(grpcContext context.Context, connParams *GrpcConnectionParams, ...)
• func WithGRPCConfig(parentContext context.Context, cfg any) context.Context
• type DeleteFunc
• type DeployFunc
• type GrpcConnection
  • func (g *GrpcConnection) SetClient(client agent.AgentClient)
  • func (g *GrpcConnection) SetConn(conn *grpc.ClientConn)
• type GrpcConnectionParams
  • func GrpcTokenToConnectionParams(grpcToken string, insecureGrpc bool) (*GrpcConnectionParams, error)
• type SecretListFunc
• type WatchFunc
• type WorkerFunctions

Functions

func GetConfigFromContext

func GetConfigFromContext(ctx context.Context) any

func Init

func Init(grpcContext context.Context,
	connParams *GrpcConnectionParams,
	appConfig *config.CommonConfiguration,
	workerFuncs WorkerFunctions)

func WithGRPCConfig

func WithGRPCConfig(parentContext context.Context, cfg any) context.Context

Types

type DeleteFunc

type DeleteFunc func(context.Context, string, string) error

type DeployFunc

type DeployFunc func(context.Context, *dogger.DeploymentLogger, *v1.DeployImageRequest, *v1.VersionData) error

type GrpcConnection

type GrpcConnection struct {
	Conn   *grpc.ClientConn
	Client agent.AgentClient
}

func (*GrpcConnection) SetClient

func (g *GrpcConnection) SetClient(client agent.AgentClient)

func (*GrpcConnection) SetConn

func (g *GrpcConnection) SetConn(conn *grpc.ClientConn)

type GrpcConnectionParams

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

func GrpcTokenToConnectionParams

func GrpcTokenToConnectionParams(grpcToken string, insecureGrpc bool) (*GrpcConnectionParams, error)

type SecretListFunc

type SecretListFunc func(context.Context, string, string) ([]string, error)

type WatchFunc

type WatchFunc func(context.Context, string) []*common.ContainerStateItem

type WorkerFunctions

type WorkerFunctions struct {
	Deploy     DeployFunc
	Watch      WatchFunc
	Delete     DeleteFunc
	SecretList SecretListFunc
}