replicationv1

type BackfillDownstream struct {
	ContinuousThrough uint64      `protobuf:"varint,1,opt,name=continuous_through,json=continuousThrough,proto3" json:"continuous_through,omitempty"` // contiguous data now extends through this seq
	Remaining         []*SeqRange `protobuf:"bytes,2,rep,name=remaining,proto3" json:"remaining,omitempty"`                                           // holes still unfilled
	// contains filtered or unexported fields
}

type BackfillUpstream struct {
	Block *Block `protobuf:"bytes,1,opt,name=block,proto3" json:"block,omitempty"`
	// contains filtered or unexported fields
}

type Block struct {
	BaseSeq    uint64 `protobuf:"varint,1,opt,name=base_seq,json=baseSeq,proto3" json:"base_seq,omitempty"`
	BaseTimeUs int64  `protobuf:"varint,2,opt,name=base_time_us,json=baseTimeUs,proto3" json:"base_time_us,omitempty"`
	FrameCount uint32 `protobuf:"varint,3,opt,name=frame_count,json=frameCount,proto3" json:"frame_count,omitempty"`
	Data       []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"` // raw block bytes (compressed per journal format, passthrough)
	Compressed bool   `protobuf:"varint,5,opt,name=compressed,proto3" json:"compressed,omitempty"`
	BlockSize  uint32 `protobuf:"varint,6,opt,name=block_size,json=blockSize,proto3" json:"block_size,omitempty"` // uncompressed block size (needed to write valid journal files)
	// contains filtered or unexported fields
}

type HandshakeRequest struct {
	InstanceId   string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	HeadSeq      uint64 `protobuf:"varint,2,opt,name=head_seq,json=headSeq,proto3" json:"head_seq,omitempty"`                // boat's current head sequence
	JournalBytes uint64 `protobuf:"varint,3,opt,name=journal_bytes,json=journalBytes,proto3" json:"journal_bytes,omitempty"` // total journal bytes on boat disk
	// contains filtered or unexported fields
}

type HandshakeResponse struct {
	Cursor        uint64      `protobuf:"varint,1,opt,name=cursor,proto3" json:"cursor,omitempty"`                                      // cloud has continuous data through this seq
	Holes         []*SeqRange `protobuf:"bytes,2,rep,name=holes,proto3" json:"holes,omitempty"`                                         // gaps the cloud is missing
	LiveStartFrom uint64      `protobuf:"varint,3,opt,name=live_start_from,json=liveStartFrom,proto3" json:"live_start_from,omitempty"` // seq to start live stream from
	// contains filtered or unexported fields
}

type LiveDownstream struct {
	AckedThrough uint64 `protobuf:"varint,1,opt,name=acked_through,json=ackedThrough,proto3" json:"acked_through,omitempty"` // cloud has received live frames through this seq
	// contains filtered or unexported fields
}

type LiveFrame struct {
	Seq         uint64 `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	TimestampUs int64  `protobuf:"varint,2,opt,name=timestamp_us,json=timestampUs,proto3" json:"timestamp_us,omitempty"`
	CanId       uint32 `protobuf:"varint,3,opt,name=can_id,json=canId,proto3" json:"can_id,omitempty"` // 29-bit extended CAN ID
	Data        []byte `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type LiveStatus struct {
	HeadSeq      uint64 `protobuf:"varint,1,opt,name=head_seq,json=headSeq,proto3" json:"head_seq,omitempty"`                // boat's latest sequence
	JournalBytes uint64 `protobuf:"varint,2,opt,name=journal_bytes,json=journalBytes,proto3" json:"journal_bytes,omitempty"` // total journal bytes
	// contains filtered or unexported fields
}

type LiveUpstream struct {

	// Types that are valid to be assigned to Msg:
	//
	//	*LiveUpstream_Frame
	//	*LiveUpstream_Status
	Msg isLiveUpstream_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

type LiveUpstream_Frame struct {
	Frame *LiveFrame `protobuf:"bytes,1,opt,name=frame,proto3,oneof"`
}

type LiveUpstream_Status struct {
	Status *LiveStatus `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type ReplicationClient interface {
	// Unary handshake: authenticate, exchange sync state.
	Handshake(ctx context.Context, in *HandshakeRequest, opts ...grpc.CallOption) (*HandshakeResponse, error)
	// Stream 1: realtime frames from boat head forward.
	Live(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[LiveUpstream, LiveDownstream], error)
	// Stream 2: bulk block transfer for backfilling holes.
	Backfill(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[BackfillUpstream, BackfillDownstream], error)
}

type ReplicationServer interface {
	// Unary handshake: authenticate, exchange sync state.
	Handshake(context.Context, *HandshakeRequest) (*HandshakeResponse, error)
	// Stream 1: realtime frames from boat head forward.
	Live(grpc.BidiStreamingServer[LiveUpstream, LiveDownstream]) error
	// Stream 2: bulk block transfer for backfilling holes.
	Backfill(grpc.BidiStreamingServer[BackfillUpstream, BackfillDownstream]) error
	// contains filtered or unexported methods
}

type Replication_BackfillClient = grpc.BidiStreamingClient[BackfillUpstream, BackfillDownstream]

type Replication_BackfillServer = grpc.BidiStreamingServer[BackfillUpstream, BackfillDownstream]

type Replication_LiveClient = grpc.BidiStreamingClient[LiveUpstream, LiveDownstream]

type Replication_LiveServer = grpc.BidiStreamingServer[LiveUpstream, LiveDownstream]

type SeqRange struct {
	Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` // inclusive
	End   uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`     // exclusive
	// contains filtered or unexported fields
}

type UnimplementedReplicationServer struct{}

type UnsafeReplicationServer interface {
	// contains filtered or unexported methods
}