runner

type API interface {
	Schemas() map[string]string // TODO: cache!
}

type Caller interface {
	Call(context context.Context, req *v1.CallRequest) (*v1.CallResponse, error)
}

type Killer interface {
	Kill() error
}

type MockService struct {
	mock.Mock
}

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
}

type Service interface {
	Run() error
	Caller
	Killer
	API
}