storage

Dec 8, 2020

Changes in this version

type DataSource

+ Dial func() error

type KubernetesDataSource

+ func (kds *KubernetesDataSource) Dial() error

type MemoryDataSource

+ func (dataSource *MemoryDataSource) Dial() error

type PostgresDataSource

+ func (pds *PostgresDataSource) Dial() error

Nov 23, 2020

Changes in this version

+ func GetKubernetesClient(kubeConfigPath string) (kubernetes.Interface, error)

type DataSource

+ func FindDataSources(useKubernetes bool, kubeConfig string, usePostgres bool, databaseURL string) ([]DataSource, error)

+ Close func() error

+ EmitNewRoute func(route LogRoute) error

+ EmitRemoveRoute func(route LogRoute) error

+ Writable func() bool

type KubernetesDataSource

+ func (kds *KubernetesDataSource) EmitNewRoute(route LogRoute) error

+ func (kds *KubernetesDataSource) EmitRemoveRoute(route LogRoute) error

+ func (kds *KubernetesDataSource) Writable() bool

+ type MemoryDataSource struct

+ func CreateMemoryDataSource() *MemoryDataSource

+ func (dataSource *MemoryDataSource) AddRoute() chan LogRoute

+ func (dataSource *MemoryDataSource) Close() error

+ func (dataSource *MemoryDataSource) EmitNewRoute(route LogRoute) error

+ func (dataSource *MemoryDataSource) EmitRemoveRoute(route LogRoute) error

+ func (dataSource *MemoryDataSource) GetAllRoutes() ([]LogRoute, error)

+ func (dataSource *MemoryDataSource) RemoveRoute() chan LogRoute

+ func (dataSource *MemoryDataSource) Writable() bool

type PostgresDataSource

+ func CreatePostgresDataSourceWithURL(databaseURL string) (*PostgresDataSource, error)

+ func (pds *PostgresDataSource) Close() error

+ func (pds *PostgresDataSource) EmitNewRoute(route LogRoute) error

+ func (pds *PostgresDataSource) EmitRemoveRoute(route LogRoute) error

+ func (pds *PostgresDataSource) Writable() bool

Nov 8, 2020

Changes in this version

+ const AkkerisAppLabelKey

+ const AkkerisDynoTypeLabelKey

+ const DrainAnnotationKey

+ const HostnameAnnotationKey

+ const TagAnnotationKey

+ func GetHostNameFromTLO(kube kubernetes.Interface, obj meta.Object, useAkkerisHosts bool) string

+ type DataSource interface

+ AddRoute func() chan LogRoute

+ GetAllRoutes func() ([]LogRoute, error)

+ RemoveRoute func() chan LogRoute

+ type KubernetesDataSource struct

+ func CreateKubernetesDataSource(kube kubernetes.Interface) (*KubernetesDataSource, error)

+ func (kds *KubernetesDataSource) AddRoute() chan LogRoute

+ func (kds *KubernetesDataSource) Close() error

+ func (kds *KubernetesDataSource) GetAllRoutes() ([]LogRoute, error)

+ func (kds *KubernetesDataSource) RemoveRoute() chan LogRoute

+ type Listener interface

+ Close func() error

+ Listen func(string) error

+ NotificationChannel func() <-chan *pq.Notification

+ Ping func() error

+ type LogRoute struct

+ Endpoint string

+ Hostname string

+ Tag string

+ type PostgresDataSource struct

+ func CreatePostgresDataSource(db *sql.DB, listener Listener, init bool) (*PostgresDataSource, error)

+ func (pds *PostgresDataSource) AddRoute() chan LogRoute

+ func (pds *PostgresDataSource) GetAllRoutes() ([]LogRoute, error)

+ func (pds *PostgresDataSource) RemoveRoute() chan LogRoute