arrowflight

type AuthInfo struct {
	UserName string `json:"username"`
	DataBase string `json:"db"`
}

type AuthToken struct {
	Username  string `json:"username"`
	Timestamp int64  `json:"timestamp"`
	Salty     int64  `json:"salty"`
}

type FlightMetaClient interface {
	Database(name string) (*meta.DatabaseInfo, error)
	Authenticate(username, password string) (ui meta.User, err error)
	User(username string) (meta.User, error)
	AdminUserExists() bool
	DataNodes() ([]meta.DataNode, error)
	ShowShards() models.Rows
}

type MetaData struct {
	DataBase        string `json:"db"`
	RetentionPolicy string `json:"rp"`
	Measurement     string `json:"mst"`
}

type RecordWriter interface {
	RetryWriteRecord(database, retentionPolicy, measurement string, rec array.Record) error
}

type Service struct {
	Config *config.Config
	Logger *logger.Logger

	StatisticsPusher *statisticsPusher.StatisticsPusher

	MetaClient FlightMetaClient

	RecordWriter interface {
		RetryWriteRecord(database, retentionPolicy, measurement string, rec array.Record) error
	}
	// contains filtered or unexported fields
}