Documentation
¶
Index ¶
- Variables
- func ClientStreamInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, ...) (grpc.ClientStream, error)
- func EdgeHealthCheck(writer http.ResponseWriter, request *http.Request)
- func InitRegister() error
- func InitToken(nodeName, tk string) error
- func IsEndpointIp(addr string) bool
- func ServerStreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, ...) error
- func StartChannelzServer(addr string)
- func StartClient() (*grpc.ClientConn, ctx.Context, ctx.CancelFunc, error)
- func StartLogServer(mode string)
- func StartMetricsServer()
- func StartSendClient()
- func StartServer()
- func SyncEndPoints()
- func SyncPodIP()
- func SyncRoute(path string)
- type RegisterNode
- type RouteCache
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrMissingMetadata = status.Errorf(codes.InvalidArgument, "missing metadata") ErrInvalidToken = status.Errorf(codes.Unauthenticated, "invalid token") )
Functions ¶
func ClientStreamInterceptor ¶
func ClientStreamInterceptor(ctx context.Context, desc *grpc.StreamDesc, cc *grpc.ClientConn, method string, streamer grpc.Streamer, opts ...grpc.CallOption) (grpc.ClientStream, error)
func EdgeHealthCheck ¶
func EdgeHealthCheck(writer http.ResponseWriter, request *http.Request)
func InitRegister ¶ added in v0.8.2
func InitRegister() error
func IsEndpointIp ¶
func ServerStreamInterceptor ¶
func ServerStreamInterceptor(srv interface{}, ss grpc.ServerStream, info *grpc.StreamServerInfo, handler grpc.StreamHandler) error
func StartChannelzServer ¶
func StartChannelzServer(addr string)
func StartClient ¶
func StartClient() (*grpc.ClientConn, ctx.Context, ctx.CancelFunc, error)
func StartLogServer ¶
func StartLogServer(mode string)
func StartMetricsServer ¶ added in v0.5.0
func StartMetricsServer()
func StartSendClient ¶
func StartSendClient()
func StartServer ¶
func StartServer()
func SyncEndPoints ¶ added in v0.5.0
func SyncEndPoints()
Types ¶
type RegisterNode ¶ added in v0.8.2
type RegisterNode struct {
ClientSet *kubernetes.Clientset
Update chan struct{}
}
Source Files
Click to show internal directories.
Click to hide internal directories.