peer

Documentation

Index

• type CertsConsumer
• type CertsWatcher
  • func NewWatcher(caPath, certPath, keyPath string) *CertsWatcher
  • func (w *CertsWatcher) AddConsumer(consumer CertsConsumer)
  • func (w *CertsWatcher) GracefulStop() error
  • func (w *CertsWatcher) Name() string
  • func (w *CertsWatcher) ReadCertsAndUpdateConsumers() error
  • func (w *CertsWatcher) Start() error
  • func (w *CertsWatcher) Stop() error
• type Client
  • func NewClient(peer *v1alpha1.Peer, tlsConfig *tls.Config) *Client
  • func (c *Client) Authorize(req *api.AuthorizationRequest) (string, error)
  • func (c *Client) GetHeartbeat() error
  • func (c *Client) Peer() *v1alpha1.Peer
• type RemoteServerAuthorizationResponse

Types

type CertsConsumer

type CertsConsumer interface {
	SetPeerCertificates(parsedCertData *tls.ParsedCertData, rawCertData *tls.RawCertData) error
}

CertsConsumer represents a consumer of peer TLS certificates.

type CertsWatcher

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

CertsWatcher watches certificate updates.

func NewWatcher

func NewWatcher(caPath, certPath, keyPath string) *CertsWatcher

NewWatcher returns a new certificate files watcher.

func (*CertsWatcher) AddConsumer

func (w *CertsWatcher) AddConsumer(consumer CertsConsumer)

AddConsumer adds a new peer certificates consumer. This function is not thread-safe.

func (*CertsWatcher) GracefulStop

func (w *CertsWatcher) GracefulStop() error

GracefulStop does a graceful stop of the watcher.

func (*CertsWatcher) Name

func (w *CertsWatcher) Name() string

Name of the watcher.

func (*CertsWatcher) ReadCertsAndUpdateConsumers

func (w *CertsWatcher) ReadCertsAndUpdateConsumers() error

ReadCertsAndUpdateConsumers reads the peer certificates and updates the consumers.

func (*CertsWatcher) Start

func (w *CertsWatcher) Start() error

Start the certs watcher.

func (*CertsWatcher) Stop

func (w *CertsWatcher) Stop() error

Stop the watcher.

type Client

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

Client for accessing a remote peer.

func NewClient

func NewClient(peer *v1alpha1.Peer, tlsConfig *tls.Config) *Client

NewClient returns a new Peer API client.

func (*Client) Authorize

func (c *Client) Authorize(req *api.AuthorizationRequest) (string, error)

Authorize a request for accessing a peer exported service, yielding an access token.

func (*Client) GetHeartbeat

func (c *Client) GetHeartbeat() error

GetHeartbeat get a heartbeat from other peers.

func (*Client) Peer

func (c *Client) Peer() *v1alpha1.Peer

Peer object this client corresponds to.

type RemoteServerAuthorizationResponse

type RemoteServerAuthorizationResponse struct {
	// ServiceExists is true if the requested service exists.
	ServiceExists bool
	// Allowed is true if the request is allowed.
	Allowed bool
	// AccessToken is a token that allows accessing the requested service.
	AccessToken string
}

RemoteServerAuthorizationResponse represents an authorization response received from a remote controlplane server.