policystore

Documentation

Index

• type Config
• type PolicyStoreCore
  • func NewPolicyStoreCore(cm certManager, dsLookupService datasetLookupService, stateSync stateSyncer, ...) (*PolicyStoreCore, error)
  • func (ps *PolicyStoreCore) Handshake(ctx context.Context, node *pb.Node) (*pb.HandshakeResponse, error)
  • func (ps *PolicyStoreCore) IfritAddress() string
  • func (ps *PolicyStoreCore) PolicyStoreConfig() Config
  • func (ps *PolicyStoreCore) RunPolicyBatcher()
  • func (ps *PolicyStoreCore) Shutdown()
  • func (ps *PolicyStoreCore) Start() error
  • func (ps *PolicyStoreCore) Stop()
  • func (ps *PolicyStoreCore) StopPolicyBatcher()

Types

type Config

type Config struct {
	Name                     string
	Hostname                 string
	GossipInterval           time.Duration
	HTTPPort                 int
	GRPCPort                 int
	MulticastAcceptanceLevel float64
	NumDirectRecipients      int
	CaAddress                string
	DirectoryServerAddress   string
	DirectoryServerGPRCPort  int
	GitRepositoryPath        string
	IfritTCPPort             int
	IfritUDPPort             int
}

type PolicyStoreCore

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

func NewPolicyStoreCore

func NewPolicyStoreCore(cm certManager, dsLookupService datasetLookupService, stateSync stateSyncer, memManager membershipManager, dsManager datasetManager, config *Config) (*PolicyStoreCore, error)

func (*PolicyStoreCore) Handshake

func (ps *PolicyStoreCore) Handshake(ctx context.Context, node *pb.Node) (*pb.HandshakeResponse, error)

Handshake endpoint for nodes to join the network

func (*PolicyStoreCore) IfritAddress

func (ps *PolicyStoreCore) IfritAddress() string

func (*PolicyStoreCore) PolicyStoreConfig

func (ps *PolicyStoreCore) PolicyStoreConfig() Config

func (*PolicyStoreCore) RunPolicyBatcher

func (ps *PolicyStoreCore) RunPolicyBatcher()

Runs the policy batcher. The function blocks until it stops multicasting policy batches.

func (*PolicyStoreCore) Shutdown

func (ps *PolicyStoreCore) Shutdown()

Shut down all resources assoicated with the policy store

func (*PolicyStoreCore) Start

func (ps *PolicyStoreCore) Start() error

func (*PolicyStoreCore) Stop

func (ps *PolicyStoreCore) Stop()

func (*PolicyStoreCore) StopPolicyBatcher

func (ps *PolicyStoreCore) StopPolicyBatcher()

Stops the policy batcher.