runner

Documentation

Index

• Constants
• type Options
• type Runner
  • func New(opt *Options) Runner

Constants

const (
	// LocalRunner type using gGRPC to connect to
	LocalRunner = "local"

	// KubernetesRunner type
	KubernetesRunner = "kubernetes"
)

Types

type Options

type Options struct {
	Type                 string
	Name                 string
	ID                   string
	Version              string
	Logger               logger.Logger
	Dailer               dialer
	PortGenerator        portGenerator
	ServiceClientCreator serviceClientCreator
	LogsDirectory        string

	// Local runner options
	LocalLogFileCreator logFileCreator
	LocalCommandCreator cmdCreator
	LocalPathToBinary   string

	// Kubernetes runner options
	KubernetesKubeConfigPath   string
	KubernetesContext          string
	KubernetesNamespace        string
	KubeconfigHost             string
	KubeconfigB64Crt           string
	KubeconfigToken            string
	Kube                       kube
	KubernetesGrpcDialViaPodIP bool
	KubernetesVolumeClaimName  string
	KubernetesVolumeName       string
}

Options shows all the available options to build runner

type Runner

type Runner interface {
	Run() error
	Kill() error
	Call(context context.Context, req *v1.CallRequest) (*v1.CallResponse, error)
	Schemas() map[string]string
}

Runner expose an interface to run services

func New

func New(opt *Options) Runner

New builds new runner based on Options.Type