handler

Documentation

Index

• func ClientServerStreamHandler(methodDesc *desc.MethodDescriptor) func(srv interface{}, stream grpc.ServerStream) error
• func ClientStreamHandler(methodDesc *desc.MethodDescriptor) func(srv interface{}, stream grpc.ServerStream) error
• func New(database schema.Database) *databaseHandler
• func ServerStreamHandler(methodDesc *desc.MethodDescriptor) func(srv interface{}, stream grpc.ServerStream) error
• func UnaryMethodHandler(d *desc.MethodDescriptor) ...
• type DatabaseHandler
• type User_SaveBiStreamServer
• type User_SaveClientStreamServer
• type User_SaveServerStreamServer

Functions

func ClientServerStreamHandler

func ClientServerStreamHandler(methodDesc *desc.MethodDescriptor) func(srv interface{}, stream grpc.ServerStream) error

func ClientStreamHandler

func ClientStreamHandler(methodDesc *desc.MethodDescriptor) func(srv interface{}, stream grpc.ServerStream) error

func New

func New(database schema.Database) *databaseHandler

Creates a database handler for serving gRPC requests

func ServerStreamHandler

func ServerStreamHandler(methodDesc *desc.MethodDescriptor) func(srv interface{}, stream grpc.ServerStream) error

func UnaryMethodHandler

func UnaryMethodHandler(d *desc.MethodDescriptor) func(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error)

Types

type DatabaseHandler

type DatabaseHandler interface {
	Save(ctx context.Context, request *protobufs.SaveUserRequest) (*protobufs.SaveUserResponse, error)
	SaveClientStream(stream User_SaveClientStreamServer) error
	SaveServerStream(request *protobufs.SaveUserRequest, stream User_SaveServerStreamServer) error
	SaveBiStream(stream User_SaveBiStreamServer) error
}

type User_SaveBiStreamServer

type User_SaveBiStreamServer interface {
	Send(*protobufs.SaveUserResponse) error
	Recv() (*protobufs.SaveUserRequest, error)
	grpc.ServerStream
}

type User_SaveClientStreamServer

type User_SaveClientStreamServer interface {
	SendAndClose(*protobufs.SaveUserResponse) error
	Recv() (*protobufs.SaveUserRequest, error)
	grpc.ServerStream
}

type User_SaveServerStreamServer

type User_SaveServerStreamServer interface {
	Send(*protobufs.SaveUserResponse) error
	grpc.ServerStream
}