registry

Documentation

Index

• Constants
• type Discovery
• type Instance
  • func NewInstance() *Instance
  • func Unmarshal(val []byte) (*Instance, error)
  • func (instance *Instance) InstanceName() string
  • func (instance *Instance) Marshal() string
  • func (instance *Instance) String() string
• type Registry
• type Watcher

Constants

const (
	ServerName string = "Tdtm"
	Version    string = "v1"
)

Types

type Discovery

type Discovery interface {
	Watch(ctx context.Context, serviceName string) (Watcher, error)
}

type Instance

type Instance struct {
	Id      string `json:"id"`
	Name    string `json:"name"`
	Version string `json:"version"`
	// examples:
	// http://127.0.0.1:8080
	Nodes []string `json:"node"`
}

func NewInstance

func NewInstance() *Instance

func Unmarshal

func Unmarshal(val []byte) (*Instance, error)

func (*Instance) InstanceName

func (instance *Instance) InstanceName() string

func (*Instance) Marshal

func (instance *Instance) Marshal() string

func (*Instance) String

func (instance *Instance) String() string

type Registry

type Registry interface {
	Register(ctx context.Context, instance *Instance) error
	DeRegister(ctx context.Context, instance *Instance) error
}

type Watcher

type Watcher interface {
	GetInstances() ([]*Instance, error)
	Next() ([]*Instance, error)
	Stop() error
}