rpc

package

v0.3.0-alpha Latest Latest Go to latest Published: Jun 16, 2022 License: MIT Imports: 29 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/c13n-io/c13n-go

Documentation ¶

Index ¶

func NewChannelServiceServer(app *app.App) pb.ChannelServiceServer
func NewContactServiceServer(app *app.App) pb.ContactServiceServer
func NewDiscussionServiceServer(app *app.App) pb.DiscussionServiceServer
func NewMessageServiceServer(app *app.App) pb.MessageServiceServer
func NewNodeInfoServiceServer(app *app.App) pb.NodeInfoServiceServer
func NewPaymentServiceServer(app *app.App) pb.PaymentServiceServer
func WithBasicAuth(username, hashedPassword string) func(*Server) error
func WithTLS(tlsCertPath string, tlsKeyPath string) func(*Server) error
type Server
- func New(address string, app *app.App, options ...func(*Server) error) (*Server, error)
- func (s *Server) Cleanup() error

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewChannelServiceServer ¶

func NewChannelServiceServer(app *app.App) pb.ChannelServiceServer

NewChannelServiceServer initializes a new channel service.

func NewContactServiceServer ¶

func NewContactServiceServer(app *app.App) pb.ContactServiceServer

NewContactServiceServer initializes a new contact service.

func NewDiscussionServiceServer ¶

func NewDiscussionServiceServer(app *app.App) pb.DiscussionServiceServer

NewDiscussionServiceServer initializes a new discussion service.

func NewMessageServiceServer ¶

func NewMessageServiceServer(app *app.App) pb.MessageServiceServer

NewMessageServiceServer initializes a new message service.

func NewNodeInfoServiceServer ¶

func NewNodeInfoServiceServer(app *app.App) pb.NodeInfoServiceServer

NewNodeInfoServiceServer initializes a new node info service.

func NewPaymentServiceServer ¶

func NewPaymentServiceServer(app *app.App) pb.PaymentServiceServer

NewPaymentServiceServer initializes a new payment service.

func WithBasicAuth ¶

func WithBasicAuth(username, hashedPassword string) func(*Server) error

WithBasicAuth creates an authorization interceptor with the provided basic auth credentials.

func WithTLS ¶

func WithTLS(tlsCertPath string, tlsKeyPath string) func(*Server) error

WithTLS enables TLS for the Server instance.

Types ¶

type Server ¶

type Server struct {
	Log *slog.Logger

	App *app.App

	Listener net.Listener

	// Embedded field
	*grpc.Server
	// contains filtered or unexported fields
}

Server is the RPC server struct.

func New ¶

func New(address string, app *app.App, options ...func(*Server) error) (*Server, error)

New creates a new instance of Server with all services registered.

func (*Server) Cleanup ¶

func (s *Server) Cleanup() error

Cleanup cleans up and terminates the rpc server.

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
services

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