endpoint

Documentation

Index

• func LookupIPv4(endpoint string) string
• type Backend
• type ConfigService
• type DefaultPublicKeyIDSynthesizer
  • func (d DefaultPublicKeyIDSynthesizer) PublicKeyID(key any) []byte
• type Discovery
• type Identity
• type IdentityService
• type KVS
• type NetworkMember
• type Resolver
  • func (r *Resolver) GetIdentity() (view.Identity, error)
• type ResolverService
  • func NewResolverService(config ConfigService, backend Backend, is IdentityService) (*ResolverService, error)
  • func (r *ResolverService) LoadResolvers() error
• type Service
  • func NewService(kvs KVS) (*Service, error)
  • func (r *Service) AddPublicKeyExtractor(publicKeyExtractor driver.PublicKeyExtractor) error
  • func (r *Service) AddResolver(name string, domain string, addresses map[string]string, aliases []string, ...) (view.Identity, error)
  • func (r *Service) Bind(longTerm view.Identity, ephemeral view.Identity) error
  • func (r *Service) Endpoint(party view.Identity) (map[driver.PortName]string, error)
  • func (r *Service) ExtractPKI(id []byte) []byte
  • func (r *Service) GetIdentity(endpoint string, pkID []byte) (view.Identity, error)
  • func (r *Service) IsBoundTo(a view.Identity, b view.Identity) bool
  • func (r *Service) Resolve(party view.Identity) (string, view.Identity, map[driver.PortName]string, []byte, error)
  • func (r *Service) SetPublicKeyIDSynthesizer(publicKeyIDSynthesizer driver.PublicKeyIDSynthesizer)

Functions

func LookupIPv4

func LookupIPv4(endpoint string) string

Types

type Backend

type Backend interface {
	Bind(longTerm view.Identity, ephemeral view.Identity) error
	AddResolver(name string, domain string, addresses map[string]string, aliases []string, id []byte) (view.Identity, error)
}

type ConfigService

type ConfigService interface {
	GetString(key string) string
	IsSet(s string) bool
	UnmarshalKey(s string, i interface{}) error
	TranslatePath(path string) string
}

type DefaultPublicKeyIDSynthesizer

type DefaultPublicKeyIDSynthesizer struct{}

func (DefaultPublicKeyIDSynthesizer) PublicKeyID

func (d DefaultPublicKeyIDSynthesizer) PublicKeyID(key any) []byte

type Discovery

type Discovery interface {
	Peers() []NetworkMember
}

type Identity

type Identity struct {
	Path string `yaml:"path"`
}

type IdentityService

type IdentityService interface {
	DefaultIdentity() view.Identity
}

type KVS

type KVS interface {
	Exists(id string) bool
	Put(id string, state interface{}) error
	Get(id string, state interface{}) error
}

type NetworkMember

type NetworkMember struct {
	Endpoint         string
	Metadata         []byte
	PKIid            []byte
	InternalEndpoint string
}

NetworkMember is a peer's representation

type Resolver

type Resolver struct {
	Name           string
	Domain         string
	Addresses      map[driver.PortName]string
	Aliases        []string
	PKI            []byte
	PKILock        sync.RWMutex
	Id             []byte
	IdentityGetter func() (view.Identity, []byte, error)
}

func (*Resolver) GetIdentity

func (r *Resolver) GetIdentity() (view.Identity, error)

type ResolverService

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

func NewResolverService

func NewResolverService(config ConfigService, backend Backend, is IdentityService) (*ResolverService, error)

NewResolverService returns a new instance of the view-sdk endpoint resolverService

func (*ResolverService) LoadResolvers

func (r *ResolverService) LoadResolvers() error

type Service

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

func NewService

func NewService(kvs KVS) (*Service, error)

NewService returns a new instance of the view-sdk endpoint service

func (*Service) AddPublicKeyExtractor

func (r *Service) AddPublicKeyExtractor(publicKeyExtractor driver.PublicKeyExtractor) error

func (*Service) AddResolver

func (r *Service) AddResolver(name string, domain string, addresses map[string]string, aliases []string, id []byte) (view.Identity, error)

func (*Service) Bind

func (r *Service) Bind(longTerm view.Identity, ephemeral view.Identity) error

func (*Service) Endpoint

func (r *Service) Endpoint(party view.Identity) (map[driver.PortName]string, error)

func (*Service) ExtractPKI

func (r *Service) ExtractPKI(id []byte) []byte

func (*Service) GetIdentity

func (r *Service) GetIdentity(endpoint string, pkID []byte) (view.Identity, error)

func (*Service) IsBoundTo

func (r *Service) IsBoundTo(a view.Identity, b view.Identity) bool

func (*Service) Resolve

func (r *Service) Resolve(party view.Identity) (string, view.Identity, map[driver.PortName]string, []byte, error)

func (*Service) SetPublicKeyIDSynthesizer

func (r *Service) SetPublicKeyIDSynthesizer(publicKeyIDSynthesizer driver.PublicKeyIDSynthesizer)