grpcsystem

Documentation

Overview

Package grpcsystem manages connecting, loading, monitoring, and disconnecting of gRPC plugins.

Index

• type GRPCSystem
  • func New(log ambient.AppLogger, pluginsystem ambient.PluginSystem) *GRPCSystem
  • func (s *GRPCSystem) Connect(p ambient.Plugin, middleware bool)
  • func (s *GRPCSystem) ConnectAll()
  • func (s *GRPCSystem) Disconnect()
  • func (s *GRPCSystem) Monitor(securesite ambient.SecureSite)

Types

type GRPCSystem

type GRPCSystem struct {

	// MonitoringFrequency is the minimum length of time between checks.
	// Defaults to 2 seconds.
	MonitoringFrequency  time.Duration
	RestartAutomatically bool
	// contains filtered or unexported fields
}

GRPCSystem manages connecting, loading, monitoring, and disconnecting gRPC plugins.

func New

func New(log ambient.AppLogger, pluginsystem ambient.PluginSystem) *GRPCSystem

New returns a new GRPCSystem.

func (*GRPCSystem) Connect

func (s *GRPCSystem) Connect(p ambient.Plugin, middleware bool)

Connect will connect to a new gRPC plugin, these don't have to be in the initial plugin loader.

func (*GRPCSystem) ConnectAll

func (s *GRPCSystem) ConnectAll()

ConnectAll will connect to all initial gRPC plugins in the plugin system.

func (*GRPCSystem) Disconnect

func (s *GRPCSystem) Disconnect()

Disconnect stops the gRPC clients.

func (*GRPCSystem) Monitor

func (s *GRPCSystem) Monitor(securesite ambient.SecureSite)

Monitor starts monitoring the gRPC plugins.