grpc

Documentation

Index

• func GetConfigFromContext(ctx context.Context) any
• func Init(grpcContext context.Context, connParams *ConnectionParams, ...)
• func WithGRPCConfig(parentContext context.Context, cfg any) context.Context
• type CloseFunc
• type Connection
  • func (g *Connection) SetClient(client agent.AgentClient)
  • func (g *Connection) SetConn(conn *grpc.ClientConn)
• type ConnectionParams
  • func TokenToConnectionParams(grpcToken *config.ValidJWT) *ConnectionParams
• type ContainerCommandFunc
• type ContainerLogContext
• type ContainerLogEvent
• type ContainerLogFunc
• type ContainerLogReader
• type DeleteContainersFunc
• type DeleteFunc
• type DeployFunc
• type SecretListFunc
• type SelfUpdateFunc
• type WatchFunc
• type WorkerFunctions

Functions

func GetConfigFromContext

func GetConfigFromContext(ctx context.Context) any

func Init

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

func WithGRPCConfig

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

Types

type CloseFunc

type CloseFunc func(context.Context, agent.CloseReason) error

type Connection

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

func (*Connection) SetClient

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

func (*Connection) SetConn

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

type ConnectionParams

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

func TokenToConnectionParams

func TokenToConnectionParams(grpcToken *config.ValidJWT) *ConnectionParams

type ContainerCommandFunc

type ContainerCommandFunc func(context.Context, *common.ContainerCommandRequest) error

type ContainerLogContext

type ContainerLogContext struct {
	Reader     ContainerLogReader
	EnableEcho bool
}

type ContainerLogEvent

type ContainerLogEvent struct {
	Message string
	Error   error
}

type ContainerLogFunc

type ContainerLogFunc func(context.Context, *agent.ContainerLogRequest) (*ContainerLogContext, error)

type ContainerLogReader

type ContainerLogReader interface {
	Next() <-chan ContainerLogEvent
	Close() error
}

type DeleteContainersFunc

type DeleteContainersFunc func(context.Context, *common.DeleteContainersRequest) error

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 SecretListFunc

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

type SelfUpdateFunc

type SelfUpdateFunc func(context.Context, string, int32) error

type WatchFunc

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

type WorkerFunctions

type WorkerFunctions struct {
	Deploy           DeployFunc
	Watch            WatchFunc
	Delete           DeleteFunc
	SecretList       SecretListFunc
	SelfUpdate       SelfUpdateFunc
	Close            CloseFunc
	ContainerCommand ContainerCommandFunc
	DeleteContainers DeleteContainersFunc
	ContainerLog     ContainerLogFunc
}