rpcplatform

README

RPCPlatform

An easy-to-use platform for creating microservices without complex infrastructure solutions. Only etcd required. Out of the box you get a service discovery, tracing between services and other useful things. gRPC is used for communication between services.

etcd required

If there is no etcd in your infrastructure, you can install it from a docker container for tests:

docker run -d \
  -p 2379:2379 \
  -p 2380:2380 \
  --name etcd gcr.io/etcd-development/etcd:v3.6.5 \
  /usr/local/bin/etcd \
  --name etcd \
  --initial-advertise-peer-urls http://127.0.0.1:2380 --listen-peer-urls http://0.0.0.0:2380 \
  --advertise-client-urls http://127.0.0.1:2379 --listen-client-urls http://0.0.0.0:2379 \
  --initial-cluster etcd=http://127.0.0.1:2380

Of course, you can use docker in production or install etcd using your favorite package manager. Just remember that the example above is for testing purposes!

Usage examples

• QuickStart: contains the simplest example without additional features
• OpenTelemetry: example with connecting distributed tracing systems
• Attributes: example using additional settings for client and server

Documentation

Index

• type Client
  • func (c *Client) Client() *grpc.ClientConn
• type RPCPlatform
  • func New(etcdPrefix string, etcdClient *etcd.Client, options ...func(*config.Platform)) (*RPCPlatform, error)
  • func (p *RPCPlatform) Lookup(ctx context.Context, name string, watch bool) (<-chan map[string]*serverinfo.ServerInfo, error)
  • func (p *RPCPlatform) NewClient(target string, options ...func(*config.Client)) (*Client, error)
  • func (p *RPCPlatform) NewServer(name, addr string, options ...func(*config.Server)) (*Server, error)
• type Server
  • func (s *Server) ID() string
  • func (s *Server) Serve() error
  • func (s *Server) Server() *grpc.Server

Types

type Client

type Client struct {
	// contains filtered or unexported fields
}

func (*Client) Client

func (c *Client) Client() *grpc.ClientConn

Client return the original gRPC ClientConn object.

type RPCPlatform

type RPCPlatform struct {
	// contains filtered or unexported fields
}

func New

func New(etcdPrefix string, etcdClient *etcd.Client, options ...func(*config.Platform)) (*RPCPlatform, error)

New creates an RPCPlatform object for further creation of clients and servers. All methods of this object are thread safe. You can create this object once and use it in different places in your program.

func (*RPCPlatform) Lookup

func (p *RPCPlatform) Lookup(ctx context.Context, name string, watch bool) (<-chan map[string]*serverinfo.ServerInfo, error)

Lookup returns information about available servers by name. If the watch is set to true, a new portion of data will be provided with each change. Otherwise the channel will be closed immediately after the first data is written. The keys of the returned map are server IDs.

func (*RPCPlatform) NewClient

func (p *RPCPlatform) NewClient(target string, options ...func(*config.Client)) (*Client, error)

NewClient creates a new client. You need to provide the target server name.

func (*RPCPlatform) NewServer

func (p *RPCPlatform) NewServer(name, addr string, options ...func(*config.Server)) (*Server, error)

NewServer creates a new server. You need to provide the server name and listening address.

type Server

type Server struct {
	// contains filtered or unexported fields
}

func (*Server) ID

func (s *Server) ID() string

ID return the server identifier.

func (*Server) Serve

func (s *Server) Serve() error

Serve starts the gRPC Server and return error if it occurs.

func (*Server) Server

func (s *Server) Server() *grpc.Server

Server return the original gRPC Server object.