grpcserver

package
v0.4.26 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 28, 2023 License: MIT Imports: 17 Imported by: 0

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 (*HealthService) Watch added in v0.4.21

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

func NewServer(ctx context.Context, s *Service, _ tracing.Handler, logger meshlogger.Logger) (*Server, error)

func (*Server) Shutdown added in v0.4.21

func (s *Server) Shutdown() error

func (*Server) Start added in v0.4.21

func (s *Server) Start(ctx context.Context) error

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL