registry

package

v0.2.19 Latest Latest Go to latest Published: Jul 5, 2026 License: MPL-2.0 Imports: 7 Imported by: 0

Details

View Source

const DefaultPort = 5858

DefaultPort Default port for op service

This section is empty.

This section is empty.

type Node struct {
	Key     string `json:"key"`
	Address string `json:"address"`
	Port    int    `json:"port"`
}

Node A node that can execute an operation

type Registry struct {
	Conf   config.Config
	Logger *zap.Logger
	Name   string `json:"name,omitempty"`
}

func New(conf config.Config, logger *zap.Logger) Registry

New Create a Registry Object

func (reg *Registry) FixedNodes() ([]*Node, error)

FixedNodes Get the fixed nodes that have been configured

func (reg *Registry) NodeByFixed(op operation.Operation) (*Node, error)

NodeByFixed For a given operation, find best non-ring node