client

type ActiveStreamFun func(c context.Context, sessionId string, clientOpts *VwPubClientOpts, stream *pubproto.PubConnect_DoWorkClient)

type VwPubClientOpts struct {
	ServerAddr    string
	AppName       string
	CodeId        int
	Version       string
	Secret        string
	SessionId     string
	NsName        string
	PodName       string
	ContainerName string
	RecvHandler   func(d *pubproto.WorkDetail) (pubproto.WorkDetail, error)
	TSL           VwPubClientTsl
	StopSign      chan int
}

type VwPubClientTsl struct {
	ServerName  string
	CertContent string
}