cloud

Documentation

Index

• type ConfigurationProvider
  • func NewConfigurationProvider(cloudSettings Settings) *ConfigurationProvider
  • func (cp *ConfigurationProvider) FreeNode(role member.PrimaryRole, nodeRef reference.Global)
  • func (cp *ConfigurationProvider) GetAppConfigs() []configuration.Configuration
  • func (cp ConfigurationProvider) GetCertManagerFactory() insapp.CertManagerFactoryFunc
  • func (cp ConfigurationProvider) GetDefaultConfig() configuration.Configuration
  • func (cp ConfigurationProvider) GetKeyStoreFactory() insapp.KeyStoreFactoryFunc
  • func (cp *ConfigurationProvider) GetNamedConfig(refStr string) configuration.Configuration
  • func (cp *ConfigurationProvider) GetRunningNodesMap() map[reference.Global]configuration.Configuration
  • func (cp *ConfigurationProvider) RunNode(role member.PrimaryRole) reference.Global
  • func (cp *ConfigurationProvider) SetFileLogging()
• type InMemoryKeyStore
  • func (ks InMemoryKeyStore) GetPrivateKey(string) (crypto.PrivateKey, error)
• type NetworkController
  • func NewController() *NetworkController
  • func (n *NetworkController) Distribute(_ context.Context, packet pulsar.PulsePacket)
  • func (n *NetworkController) NetworkInitFunc(cfg configuration.Configuration, cm *component.Manager) (insapp.NetworkSupport, network.Status, error)
  • func (n *NetworkController) PartialDistribute(_ context.Context, packet pulsar.PulsePacket, ...)
• type NodeConfiguration
  • func (c NodeConfiguration) IsZero() bool
• type PulsarWrapper
  • func NewPulsarWrapper(distributor pulsar.PulseDistributor, cfg configuration.PulsarConfiguration, ...) *PulsarWrapper
  • func (p *PulsarWrapper) Start(ctx context.Context) error
  • func (p *PulsarWrapper) Stop(ctx context.Context) error
• type Settings

Types

type ConfigurationProvider

type ConfigurationProvider struct {
	PulsarConfig       configuration.PulsarConfiguration
	BaseConfig         configuration.Configuration
	CertificateFactory insapp.CertManagerFactoryFunc
	KeyFactory         insapp.KeyStoreFactoryFunc

	FixedConfigs []configuration.Configuration
	// contains filtered or unexported fields
}

func NewConfigurationProvider

func NewConfigurationProvider(cloudSettings Settings) *ConfigurationProvider

func (*ConfigurationProvider) FreeNode

func (cp *ConfigurationProvider) FreeNode(role member.PrimaryRole, nodeRef reference.Global)

func (*ConfigurationProvider) GetAppConfigs

func (cp *ConfigurationProvider) GetAppConfigs() []configuration.Configuration

func (ConfigurationProvider) GetCertManagerFactory

func (cp ConfigurationProvider) GetCertManagerFactory() insapp.CertManagerFactoryFunc

func (ConfigurationProvider) GetDefaultConfig

func (cp ConfigurationProvider) GetDefaultConfig() configuration.Configuration

func (ConfigurationProvider) GetKeyStoreFactory

func (cp ConfigurationProvider) GetKeyStoreFactory() insapp.KeyStoreFactoryFunc

func (*ConfigurationProvider) GetNamedConfig

func (cp *ConfigurationProvider) GetNamedConfig(refStr string) configuration.Configuration

func (*ConfigurationProvider) GetRunningNodesMap

func (cp *ConfigurationProvider) GetRunningNodesMap() map[reference.Global]configuration.Configuration

func (*ConfigurationProvider) RunNode

func (cp *ConfigurationProvider) RunNode(role member.PrimaryRole) reference.Global

func (*ConfigurationProvider) SetFileLogging

func (cp *ConfigurationProvider) SetFileLogging()

type InMemoryKeyStore

type InMemoryKeyStore struct {
	Key crypto.PrivateKey
}

func (InMemoryKeyStore) GetPrivateKey

func (ks InMemoryKeyStore) GetPrivateKey(string) (crypto.PrivateKey, error)

type NetworkController

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

func NewController

func NewController() *NetworkController

func (*NetworkController) Distribute

func (n *NetworkController) Distribute(_ context.Context, packet pulsar.PulsePacket)

func (*NetworkController) NetworkInitFunc

func (n *NetworkController) NetworkInitFunc(cfg configuration.Configuration, cm *component.Manager) (insapp.NetworkSupport, network.Status, error)

func (*NetworkController) PartialDistribute

func (n *NetworkController) PartialDistribute(_ context.Context, packet pulsar.PulsePacket, whiteList map[reference.Global]struct{})

type NodeConfiguration

type NodeConfiguration struct {
	Virtual       uint
	HeavyMaterial uint
	LightMaterial uint
}

func (NodeConfiguration) IsZero

func (c NodeConfiguration) IsZero() bool

type PulsarWrapper

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

func NewPulsarWrapper

func NewPulsarWrapper(distributor pulsar.PulseDistributor, cfg configuration.PulsarConfiguration, keyFactory insapp.KeyStoreFactoryFunc) *PulsarWrapper

func (*PulsarWrapper) Start

func (p *PulsarWrapper) Start(ctx context.Context) error

func (*PulsarWrapper) Stop

func (p *PulsarWrapper) Stop(ctx context.Context) error

type Settings

type Settings struct {
	Prepared NodeConfiguration
	Running  NodeConfiguration
	MinRoles NodeConfiguration

	MajorityRule int

	Pulsar struct {
		PulseTime int
	}
	Log struct {
		Level string
	}
	CloudFileLogging bool
}