Documentation ¶
Index ¶
Constants ¶
View Source
const ( WriteAuthSuccess string = "ArrowFlightWriteSuccessfully" WriteAuthTokenSalty int64 = 1e9 WriteAuthTokenTimeOut = 24 * time.Hour )
Variables ¶
This section is empty.
Functions ¶
func HashAuthToken ¶
func NewAuthServer ¶
func NewAuthServer(authEnabled bool) *authServer
func NewWriteServer ¶
Types ¶
type FlightMetaClient ¶
type RecordWriter ¶
type Service ¶
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 }
Service is that the protocol of arrow flight must satisfy 4 constraints. Constraint 1: the protocol must ensure data write balancing. Constraint 2: the protocol must ensure that the time of a batch of data is ordered. Constraint 3: the protocol must ensure that a batch of data belongs to the same db/rp/mst. Constraint 4: the protocol must ensure that the time field is in the last column.
Click to show internal directories.
Click to hide internal directories.