Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type HealthService ¶ added in v0.4.21
type HealthService struct {
grpc_health_v1.UnimplementedHealthServer
}
func (*HealthService) Check ¶ added in v0.4.21
func (h *HealthService) Check(ctx context.Context, in *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
func (*HealthService) Watch ¶ added in v0.4.21
func (h *HealthService) Watch(req *grpc_health_v1.HealthCheckRequest, w grpc_health_v1.Health_WatchServer) error
type Server ¶ added in v0.4.21
type Server struct {
Server *grpc.Server
Listener net.Listener
Logger meshlogger.Logger
Ctx context.Context
Host string `json:"host"`
Port string `json:"port"`
// contains filtered or unexported fields
}
func NewServer ¶ added in v0.4.21
type Service ¶
type Service struct {
Name string `json:"name"`
Host string `json:"host"`
Port string `json:"port"`
Type string `json:"type"`
Version string `json:"version"`
GitSHA string `json:"gitsha"`
StartedAt time.Time `json:"startedat"`
TraceURL string `json:"traceurl"`
Handler adapters.Handler
CloudEventsStreamer *events.CloudEventsStreamer
meshes.UnimplementedMeshServiceServer
}
func (*Service) ApplyOperation ¶
func (s *Service) ApplyOperation(ctx context.Context, req *meshes.ApplyRuleRequest) (*meshes.ApplyRuleResponse, error)
func (*Service) CloudStreamEvents ¶
func (s *Service) CloudStreamEvents(ctx *meshes.CloudEventsRequest, stream meshes.MeshService_CloudStreamEventsServer) error
Source Files
¶
- doc.go
- grpc.go
- handlers.go
- health.go
Click to show internal directories.
Click to hide internal directories.