grpc

package
v0.9.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 24, 2025 License: Apache-2.0 Imports: 56 Imported by: 0

Documentation

Overview

Package grpc implements the gRPC services defined by APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type NodeRegistries added in v0.8.0 

type NodeRegistries struct {
	StreamLiaisonNodeRegistry  NodeRegistry
	MeasureLiaisonNodeRegistry NodeRegistry
	PropertyNodeRegistry       NodeRegistry
	TraceLiaisonNodeRegistry   NodeRegistry
}

NodeRegistries contains the node registries.

type NodeRegistry added in v0.5.0 

type NodeRegistry interface {
	Locate(group, name string, shardID, replicaID 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 added in v0.5.0 

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

NewClusterNodeRegistry creates a cluster node registry.

func NewLocalNodeRegistry added in v0.5.0 

func NewLocalNodeRegistry() NodeRegistry

NewLocalNodeRegistry creates a local(fake) node registry.

type Server 

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

Server defines the gRPC server.

func NewServer 

func NewServer(_ context.Context, tir1Client, tir2Client, broadcaster queue.Client,
	schemaRegistry metadata.Repo, nr NodeRegistries, omr observability.MetricsRegistry,
	protectorService protector.Memory,
) Server

NewServer returns a new gRPC server.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.