runner

Aug 20, 2020

Changes in this version

+ const Kubernetes

+ const Local

+ type API interface

+ Schemas func() map[string]string

+ type Caller interface

+ Call func(context context.Context, req *v1.CallRequest) (*v1.CallResponse, error)

+ type Killer interface

+ Kill func() error

+ type MockService struct

+ func (_m *MockService) Call(_a0 context.Context, req *v1.CallRequest) (*v1.CallResponse, error)

+ func (_m *MockService) Kill() error

+ func (_m *MockService) Run() error

+ func (_m *MockService) Schemas() map[string]string

+ type Options struct

+ Dailer dialer

+ ID string

+ Kube kube

+ KubeconfigB64Crt string

+ KubeconfigHost string

+ KubeconfigToken string

+ KubernetesContext string

+ KubernetesGrpcDialViaPodIP bool

+ KubernetesKubeConfigPath string

+ KubernetesNamespace string

+ KubernetesVolumeClaimName string

+ KubernetesVolumeName string

+ LocalCommandCreator cmdCreator

+ LocalLogFileCreator logFileCreator

+ LocalPathToBinary string

+ Logger logger.Logger

+ LogsDirectory string

+ Name string

+ PortGenerator portGenerator

+ ServiceClientCreator serviceClientCreator

+ Type string

+ Version string

+ type Service interface

+ Run func() error

+ func New(opt *Options) Service