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
Click to show internal directories.
Click to hide internal directories.