config

Documentation

Index

• Constants
• type Context
  • func NewContext(discovery *ctypes.DiscoveryFile, scalableStoreUrl *url.URL) *Context
  • func (c *Context) AuthToken() string
  • func (c *Context) GetCaCertificates() *x509.CertPool
  • func (c *Context) GetPubSubServerAddr() string
  • func (c *Context) GetPubSubServerBindAddr() string
  • func (c *Context) GetSignedServerCertificate() tls.Certificate
  • func (c *Context) GetStreamEncryptionKey() []byte
  • func (c *Context) GetWriterIp() string
  • func (c *Context) GetWriterPort() int
  • func (c *Context) GetWriterServerAddr() string
  • func (c *Context) ScalableStoreUrl() *url.URL

Constants

const (
	WalManagerDataDir = "/eventhorizon-data/store-live"

	SeekableStorePath = "/eventhorizon-data/store-seekable"

	CompressedEncryptedStorePath = "/eventhorizon-data/store-compressed_and_encrypted"

	// using AES-256
	AesKeyLenBytes = 32

	BoltDbDir = "/eventhorizon-data"

	WriterHttpPort = 9092

	WalSizeThreshold = uint64(4 * 1024 * 1024)

	ChunkRotateThreshold = 8 * 1024 * 1024
)

Types

type Context

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

configuration context is used to pass configuration to different components

func NewContext

func NewContext(discovery *ctypes.DiscoveryFile, scalableStoreUrl *url.URL) *Context

func (*Context) AuthToken

func (c *Context) AuthToken() string

func (*Context) GetCaCertificates

func (c *Context) GetCaCertificates() *x509.CertPool

since we control both the servers and clients, it's easy being our own CA when we control both the servers and clients. Just configure our sole CA cert as the trust anchor.

func (*Context) GetPubSubServerAddr

func (c *Context) GetPubSubServerAddr() string

func (*Context) GetPubSubServerBindAddr

func (c *Context) GetPubSubServerBindAddr() string

func (*Context) GetSignedServerCertificate

func (c *Context) GetSignedServerCertificate() tls.Certificate

returns a valid server certificate for this Writer's IP address

func (*Context) GetStreamEncryptionKey

func (c *Context) GetStreamEncryptionKey() []byte

TODO: have separate key per stream, provisioned in ChildStreamCreated? the only drawback is that then you cannot directly access streams by knowing their name, but rather walk to the stream hierarchy from the root stream to the leaf. TODO: do not store this (at least in plaintext) in scalablestore

func (*Context) GetWriterIp

func (c *Context) GetWriterIp() string

func (*Context) GetWriterPort

func (c *Context) GetWriterPort() int

func (*Context) GetWriterServerAddr

func (c *Context) GetWriterServerAddr() string

func (*Context) ScalableStoreUrl

func (c *Context) ScalableStoreUrl() *url.URL