grpc

Documentation

Overview

Package grpc implements the gRPC services defined by APIs.

Index

• type NodeRegistry
  • func NewClusterNodeRegistry(pipeline queue.Client, selector node.Selector) NodeRegistry
  • func NewLocalNodeRegistry() NodeRegistry
• type Server
  • func NewServer(_ context.Context, pipeline, broadcaster queue.Client, ...) Server

Types

type NodeRegistry

type NodeRegistry interface {
	Locate(group, name string, shardID uint32) (string, error)
	fmt.Stringer
}

NodeRegistry is for locating data node with group/name of the metadata together with the shardID calculated from the incoming data.

func NewClusterNodeRegistry

func NewClusterNodeRegistry(pipeline queue.Client, selector node.Selector) NodeRegistry

NewClusterNodeRegistry creates a cluster node registry.

func NewLocalNodeRegistry

func NewLocalNodeRegistry() NodeRegistry

NewLocalNodeRegistry creates a local(fake) node registry.

type Server

type Server interface {
	run.Unit
	GetPort() *uint32
}

Server defines the gRPC server.

func NewServer

func NewServer(_ context.Context, pipeline, broadcaster queue.Client, schemaRegistry metadata.Repo, nodeRegistry NodeRegistry, omr observability.MetricsRegistry) Server

NewServer returns a new gRPC server.