grpc

package
v0.0.0-...-cee4bc5 Latest Latest
Warning

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

 Go to latest Published: Sep 11, 2023 License: MIT Imports: 21 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InterceptorLogger 

func InterceptorLogger(l *slog.Logger) logging.Logger

func InterceptorRequestID 

func InterceptorRequestID() grpc.UnaryServerInterceptor

func RequestIDFromContext 

func RequestIDFromContext(ctx context.Context) string

Types

type Broker 

type Broker interface {
	RegisterClient(id uuid.UUID, c broker.Client)
	Unregister(id uuid.UUID) error
}

type GeneratorServer 

type GeneratorServer struct {
	gpsgendproto.UnimplementedGeneratorServiceServer
	// contains filtered or unexported fields
}

func NewGeneratorServer 

func NewGeneratorServer(s generator.Service) *GeneratorServer

func (*GeneratorServer) AddRoutes 

func (s *GeneratorServer) AddRoutes(ctx context.Context, req *gpsgendproto.AddRoutesRequest) (*gpsgendproto.AddRoutesResponse, error)

func (*GeneratorServer) AddSensor 

func (s *GeneratorServer) AddSensor(ctx context.Context, req *gpsgendproto.AddSensorRequest) (*gpsgendproto.AddSensorResponse, error)

func (*GeneratorServer) FindTracker 

func (s *GeneratorServer) FindTracker(ctx context.Context, req *gpsgendproto.FindTrackerRequest) (*gpsgendproto.FindTrackerResponse, error)

func (*GeneratorServer) MoveToRoute 

func (s *GeneratorServer) MoveToRoute(ctx context.Context, req *gpsgendproto.MoveToRouteRequest) (*gpsgendproto.MoveToRouteResponse, error)

func (*GeneratorServer) MoveToRouteByID 

func (s *GeneratorServer) MoveToRouteByID(ctx context.Context, req *gpsgendproto.MoveToRouteByIDRequest) (*gpsgendproto.MoveToRouteByIDResponse, error)

func (*GeneratorServer) MoveToSegment 

func (s *GeneratorServer) MoveToSegment(ctx context.Context, req *gpsgendproto.MoveToSegmentRequest) (*gpsgendproto.MoveToSegmentResponse, error)

func (*GeneratorServer) MoveToTrack 

func (s *GeneratorServer) MoveToTrack(ctx context.Context, req *gpsgendproto.MoveToTrackRequest) (*gpsgendproto.MoveToTrackResponse, error)

func (*GeneratorServer) MoveToTrackByID 

func (s *GeneratorServer) MoveToTrackByID(ctx context.Context, req *gpsgendproto.MoveToTrackByIDRequest) (*gpsgendproto.MoveToTrackByIDResponse, error)

func (*GeneratorServer) NewTracker 

func (s *GeneratorServer) NewTracker(ctx context.Context, req *gpsgendproto.NewTrackerRequest) (*gpsgendproto.NewTrackerResponse, error)

func (*GeneratorServer) RemoveRoute 

func (s *GeneratorServer) RemoveRoute(ctx context.Context, req *gpsgendproto.RemoveRouteRequest) (*gpsgendproto.RemoveRouteResponse, error)

func (*GeneratorServer) RemoveSensor 

func (s *GeneratorServer) RemoveSensor(ctx context.Context, req *gpsgendproto.RemoveSensorRequest) (*gpsgendproto.RemoveSensorResponse, error)

func (*GeneratorServer) RemoveTracker 

func (s *GeneratorServer) RemoveTracker(ctx context.Context, req *gpsgendproto.RemoveTrackerRequest) (*gpsgendproto.RemoveTrackerResponse, error)

func (*GeneratorServer) ResetNavigator 

func (s *GeneratorServer) ResetNavigator(ctx context.Context, req *gpsgendproto.ResetNavigatorRequest) (*gpsgendproto.ResetNavigatorResponse, error)

func (*GeneratorServer) ResetRoutes 

func (s *GeneratorServer) ResetRoutes(ctx context.Context, req *gpsgendproto.ResetRoutesRequest) (*gpsgendproto.ResetRoutesResponse, error)

func (*GeneratorServer) ResumeTracker 

func (s *GeneratorServer) ResumeTracker(ctx context.Context, req *gpsgendproto.ResumeTrackerRequest) (*gpsgendproto.ResumeTrackerResponse, error)

func (*GeneratorServer) RouteAt 

func (s *GeneratorServer) RouteAt(ctx context.Context, req *gpsgendproto.RouteAtRequest) (*gpsgendproto.RouteAtResponse, error)

func (*GeneratorServer) RouteByID 

func (s *GeneratorServer) RouteByID(ctx context.Context, req *gpsgendproto.RouteByIDRequest) (*gpsgendproto.RouteByIDResponse, error)

func (*GeneratorServer) Routes 

func (s *GeneratorServer) Routes(ctx context.Context, req *gpsgendproto.RoutesRequest) (*gpsgendproto.RoutesResponse, error)

func (*GeneratorServer) SearchTrackers 

func (s *GeneratorServer) SearchTrackers(ctx context.Context, req *gpsgendproto.SearchTrackersRequest) (*gpsgendproto.SearchTrackersResponse, error)

func (*GeneratorServer) Sensors 

func (s *GeneratorServer) Sensors(ctx context.Context, req *gpsgendproto.SensorsRequest) (*gpsgendproto.SensorsResponse, error)

func (*GeneratorServer) ShutdownTracker 

func (s *GeneratorServer) ShutdownTracker(ctx context.Context, req *gpsgendproto.ShutdownTrackerRequest) (*gpsgendproto.ShutdownTrackerResponse, error)

func (*GeneratorServer) StartTracker 

func (s *GeneratorServer) StartTracker(ctx context.Context, req *gpsgendproto.StartTrackerRequest) (*gpsgendproto.StartTrackerResponse, error)

func (*GeneratorServer) Stats 

func (s *GeneratorServer) Stats(ctx context.Context, req *gpsgendproto.EmptyRequest) (*gpsgendproto.StatsResponse, error)

func (*GeneratorServer) StopTracker 

func (s *GeneratorServer) StopTracker(ctx context.Context, req *gpsgendproto.StopTrackerRequest) (*gpsgendproto.StopTrackerResponse, error)

func (*GeneratorServer) Sync 

func (s *GeneratorServer) Sync(ctx context.Context, req *gpsgendproto.SyncRequest) (*gpsgendproto.SyncResponse, error)

func (*GeneratorServer) ToNextRoute 

func (s *GeneratorServer) ToNextRoute(ctx context.Context, req *gpsgendproto.ToNextRouteRequest) (*gpsgendproto.ToNextRouteResponse, error)

func (*GeneratorServer) ToPrevRoute 

func (s *GeneratorServer) ToPrevRoute(ctx context.Context, req *gpsgendproto.ToPrevRouteRequest) (*gpsgendproto.ToPrevRouteResponse, error)

func (*GeneratorServer) TrackerState 

func (s *GeneratorServer) TrackerState(ctx context.Context, req *gpsgendproto.TrackerStateRequest) (*gpsgendproto.TrackerStateResponse, error)

func (*GeneratorServer) UpdateTracker 

func (s *GeneratorServer) UpdateTracker(ctx context.Context, req *gpsgendproto.UpdateTrackerRequest) (*gpsgendproto.UpdateTrackerResponse, error)

type TrackerServer 

type TrackerServer struct {
	gpsgendproto.UnimplementedTrackerServiceServer
	// contains filtered or unexported fields
}

func NewTrackServer 

func NewTrackServer(b Broker, logger *slog.Logger) *TrackerServer

func (*TrackerServer) GetClientsInfo 

func (s *TrackerServer) GetClientsInfo(ctx context.Context, _ *gpsgendproto.GetClientsInfoRequest) (*gpsgendproto.GetClientsInfoResponse, error)

func (*TrackerServer) Subscribe 

func (s *TrackerServer) Subscribe(
	req *gpsgendproto.SubscribeRequest,
	stream gpsgendproto.TrackerService_SubscribeServer,
) error

func (*TrackerServer) Unsubscribe 

func (s *TrackerServer) Unsubscribe(ctx context.Context, req *gpsgendproto.UnsubscribeRequest) (*gpsgendproto.UnsubscribeResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.