cloud

package
v0.0.0-...-05bc493 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 20, 2023 License: MIT Imports: 44 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 (*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 (*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
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL