kubenetworks/kubevpn

package action

import (
    "path/filepath"
    "sync"
    "time"

    "gopkg.in/natefinch/lumberjack.v2"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    "k8s.io/client-go/metadata/metadatainformer"

    "github.com/wencaiwulue/kubevpn/v2/pkg/config"
    "github.com/wencaiwulue/kubevpn/v2/pkg/daemon/rpc"
    "github.com/wencaiwulue/kubevpn/v2/pkg/handler"
)

type Server struct {
    rpc.UnimplementedDaemonServer

    Cancel    func()
    GetClient func(isSudo bool) rpc.DaemonClient
    IsSudo    bool
    LogFile   *lumberjack.Logger
    Lock      sync.Mutex

    t                time.Time
    connect          *handler.ConnectOptions
    clone            *handler.CloneOptions
    secondaryConnect []*handler.ConnectOptions

    resourceLists []*metav1.APIResourceList
    informer      metadatainformer.SharedInformerFactory

    ID string
}

func GetDaemonLogPath() string {
    return filepath.Join(config.DaemonPath, config.LogFile)
}