daemon

Documentation

Index

• func CreateDowngradingHandler(grpcServer *grpc.Server, httpHandler http.Handler) http.Handler
• func GetClient(isSudo bool) (cli rpc.DaemonClient)
• func GetClientWithoutCache(ctx context.Context, isSudo bool) (cli rpc.DaemonClient, conn *grpc.ClientConn, err error)
• func GetHttpClient(isSudo bool) *http.Client
• func GetTCPClient(isSudo bool) net.Conn
• func StartupDaemon(ctx context.Context, path ...string) error
• type SvrOption
  • func (o *SvrOption) Start(ctx context.Context) error
  • func (o *SvrOption) Stop()

Functions

func CreateDowngradingHandler

func CreateDowngradingHandler(grpcServer *grpc.Server, httpHandler http.Handler) http.Handler

CreateDowngradingHandler takes a gRPC server and a plain HTTP handler, and returns an HTTP handler that has the capability of handling HTTP requests and gRPC requests that may require downgrading the response to gRPC-Web or gRPC-WebSocket.

if r.ProtoMajor == 2 && strings.HasPrefix(
	r.Header.Get("Content-Type"), "application/grpc") {
	grpcServer.ServeHTTP(w, r)
} else {
	yourMux.ServeHTTP(w, r)
}

func GetClient

func GetClient(isSudo bool) (cli rpc.DaemonClient)

func GetClientWithoutCache

func GetClientWithoutCache(ctx context.Context, isSudo bool) (cli rpc.DaemonClient, conn *grpc.ClientConn, err error)

func GetHttpClient

func GetHttpClient(isSudo bool) *http.Client

func GetTCPClient

func GetTCPClient(isSudo bool) net.Conn

func StartupDaemon

func StartupDaemon(ctx context.Context, path ...string) error

Types

type SvrOption

type SvrOption struct {
	IsSudo bool
	ID     string
	// contains filtered or unexported fields
}

func (*SvrOption) Start

func (o *SvrOption) Start(ctx context.Context) error

func (*SvrOption) Stop

func (o *SvrOption) Stop()