handler

package

v0.0.0-...-52d38b8 Latest Latest Go to latest Published: Oct 31, 2020 License: BSD-3-Clause Imports: 7 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/featme-inc/agoradb

Links

Open Source Insights

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

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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
}

Source Files ¶

View all Source files

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