control

type Account struct {
	ID        []byte `gorm:"primary_key"`
	Namespace string

	Data sqljson.Data

	CreatedAt time.Time
	UpdatedAt time.Time
}

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

type ActivityLog struct {
	Id        int64 `gorm:"primary_key"`
	Event     []byte
	CreatedAt time.Time
}

type ActivityReader struct {
	C chan []*ActivityLog
	// contains filtered or unexported fields
}

type Client struct {
	L hclog.Logger
	// contains filtered or unexported fields
}

type ClientConfig struct {
	Logger     hclog.Logger
	InstanceId *pb.ULID
	Id         *pb.ULID
	GRPCConn   *grpc.ClientConn
	Client     pb.ControlServicesClient
	Token      string
	Addr       string
	Version    string
	S3Bucket   string
	Session    *session.Session
	WorkDir    string
	Insecure   bool

	// The kubernetes deployment name used for the service using this client
	K8Deployment string

	// Where hub integrates it's handler for the hzn protocol
	NextProto map[string]func(hs *http.Server, tlsConn *tls.Conn, h http.Handler)

	FilterRoute        func(*pb.ServiceRoute) bool
	InsecureSkipVerify bool
}

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

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

type Hub struct {
	StableID   []byte `gorm:"primary_key"`
	InstanceID []byte

	ConnectionInfo []byte
	LastCheckin    time.Time

	CreatedAt time.Time
}

type LabelLink struct {
	ID int `gorm:"primary_key"`

	Account   *Account
	AccountID []byte

	Labels string
	Target string

	CreatedAt time.Time
	UpdatedAt time.Time
}

type LockManager interface {
	GetLock(id, val string) (io.Closer, error)
	GetValue(id string) (string, error)
}

type LogCleaner struct {
	DB *gorm.DB
}

type ManagementClient struct {
	ID        []byte `gorm:"primary_key"`
	Namespace string
}

type NPNHandler func(hs *http.Server, c *tls.Conn, h http.Handler)

type Peer struct {
	PublicKey []byte
}

type RouteCalculation struct {
	All  []*pb.ServiceRoute
	Best []*pb.ServiceRoute
	// contains filtered or unexported fields
}

type Server struct {
	L hclog.Logger
	// contains filtered or unexported fields
}

type ServerConfig struct {
	DB *gorm.DB

	Logger hclog.Logger

	RegisterToken string
	OpsToken      string

	VaultClient *api.Client
	VaultPath   string
	KeyId       string

	// If no vault client is specified, this is used instead.
	SigningKey ed25519.PrivateKey

	AwsSession *session.Session
	Bucket     string

	ASNDB string

	HubAccessKey string
	HubSecretKey string

	// The docker image that hubs should be used, this is advertised to the hubs
	// so they can act on it.
	HubImageTag string

	DataDogAddr       string
	DisablePrometheus bool

	LockManager LockManager
}

type Service struct {
	ID int64 `gorm:"primary_key"`

	ServiceId []byte

	HubId []byte

	Account   *Account
	AccountId []byte

	Type        string
	Description string
	Labels      pq.StringArray

	CreatedAt time.Time
	UpdatedAt time.Time
}