...

Text file src/github.com/twmb/franz-go/generate/definitions/35_describe_log_dirs

Documentation: github.com/twmb/franz-go/generate/definitions

     1// DescribeLogDirsRequest requests directory information for topic partitions.
     2// This request was added in support of KIP-113.
     3DescribeLogDirsRequest => key 35, max version 4, flexible v2+
     4  // Topics is an array of topics to describe the log dirs of. If this is
     5  // null, the response includes all topics and all of their partitions.
     6  Topics: nullable[=>]
     7    // Topic is a topic to describe the log dir of.
     8    Topic: string
     9    // Partitions contains topic partitions to describe the log dirs of.
    10    Partitions: [int32]
    11
    12// DescribeLogDirsResponse is returned from a DescribeLogDirsRequest.
    13DescribeLogDirsResponse =>
    14  ThrottleMillis(1)
    15  // The error code, or 0 if there was no error.
    16  ErrorCode: int16 // v3+
    17  // Dirs pairs log directories with the topics and partitions that are
    18  // stored in those directores.
    19  Dirs: [=>]
    20    // ErrorCode is the error code returned for describing log dirs.
    21    //
    22    // KAFKA_STORAGE_ERROR is returned if the log directory is offline.
    23    ErrorCode: int16
    24    // Dir is the absolute path of a log directory.
    25    Dir: string
    26    // Topics is an array of topics within a log directory.
    27    Topics: [=>]
    28      // Topic is the name of a Kafka topic.
    29      Topic: string
    30      // Partitions is the set of queried partitions for a topic that are
    31      // within a log directory.
    32      Partitions: [=>]
    33        // Partition is a partition ID.
    34        Partition: int32
    35        // Size is the total size of the log sements of this partition, in bytes.
    36        Size: int64
    37        // OffsetLag is how far behind the log end offset is compared to
    38        // the partition's high watermark (if this is the current log for
    39        // the partition) or compared to the current replica's log end
    40        // offset (if this is the future log for the patition).
    41        //
    42        // The math is,
    43        //
    44        // if IsFuture, localLogEndOffset - futurelogEndOffset.
    45        //
    46        // otherwise, max(localHighWatermark - logEndOffset, 0).
    47        OffsetLag: int64
    48        // IsFuture is true if this replica was created by an
    49        // AlterReplicaLogDirsRequest and will replace the current log of the
    50        // replica in the future.
    51        IsFuture: bool
    52    // TotalBytes is the total size in bytes of the volume the log directory is
    53    // in.
    54    TotalBytes: int64(-1) // v4+
    55    // UsableBytes is the usable size in bytes of the volume the log directory
    56    // is in.
    57    UsableBytes: int64(-1) // v4+

View as plain text