grpc

package

v0.0.0-...-4de0c4c Latest Latest Go to latest Published: Oct 14, 2024 License: AGPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

git.solsynth.dev/hydrogen/dealer

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Server ¶

type Server struct {
	proto.UnimplementedServiceDirectoryServer
	proto.UnimplementedStreamControllerServer
	proto.UnimplementedPostmanServer
	proto.UnimplementedAuthServer
	// contains filtered or unexported fields
}

func NewServer ¶

func NewServer() *Server

func (*Server) AddService ¶

func (v *Server) AddService(ctx context.Context, info *proto.ServiceInfo) (*proto.AddServiceResponse, error)

func (*Server) BroadcastDeletion ¶

func (v *Server) BroadcastDeletion(ctx context.Context, request *proto.DeletionRequest) (*proto.DeletionResponse, error)

func (*Server) Check ¶

func (v *Server) Check(ctx context.Context, request *health.HealthCheckRequest) (*health.HealthCheckResponse, error)

func (*Server) CountStreamConnection ¶

func (v *Server) CountStreamConnection(ctx context.Context, request *proto.CountConnectionRequest) (*proto.CountConnectionResponse, error)

func (*Server) DeliverEmail ¶

func (v *Server) DeliverEmail(ctx context.Context, request *proto.DeliverEmailRequest) (*proto.DeliverResponse, error)

func (*Server) DeliverEmailBatch ¶

func (v *Server) DeliverEmailBatch(ctx context.Context, request *proto.DeliverEmailBatchRequest) (*proto.DeliverResponse, error)

func (*Server) DeliverNotification ¶

func (v *Server) DeliverNotification(ctx context.Context, request *proto.DeliverNotificationRequest) (*proto.DeliverResponse, error)

func (*Server) DeliverNotificationBatch ¶

func (v *Server) DeliverNotificationBatch(ctx context.Context, request *proto.DeliverNotificationBatchRequest) (*proto.DeliverResponse, error)

func (*Server) GetService ¶

func (v *Server) GetService(ctx context.Context, request *proto.GetServiceRequest) (*proto.GetServiceResponse, error)

func (*Server) ListService ¶

func (v *Server) ListService(ctx context.Context, request *proto.ListServiceRequest) (*proto.ListServiceResponse, error)

func (*Server) Listen ¶

func (v *Server) Listen() error

func (*Server) PushStream ¶

func (v *Server) PushStream(ctx context.Context, request *proto.PushStreamRequest) (*proto.PushStreamResponse, error)

func (*Server) PushStreamBatch ¶

func (v *Server) PushStreamBatch(ctx context.Context, request *proto.PushStreamBatchRequest) (*proto.PushStreamResponse, error)

func (*Server) RemoveService ¶

func (v *Server) RemoveService(ctx context.Context, request *proto.RemoveServiceRequest) (*proto.RemoveServiceResponse, error)

func (*Server) Watch ¶

func (v *Server) Watch(request *health.HealthCheckRequest, server health.Health_WatchServer) error

Source Files ¶

View all Source files

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