tunnel

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

type DirectWriter struct {
	RemoteAddrs   []string
	ReplayerId    uint32 // equal to worker-id
	BatchExecutor *executor.BatchGroupExecutor
}

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

type FileHeader struct {
	Magic    uint64
	Protocol uint32
	Checksum uint32
	Reserved [16]byte
}

type FileReader struct {
	File string
	// contains filtered or unexported fields
}

type FileWriter struct {
	// local file folder path
	Local string
	// contains filtered or unexported fields
}

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

type KafkaWriter struct {
	RemoteAddr  string
	PartitionId int // write to which partition
	// contains filtered or unexported fields
}

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

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

type MockWriter struct {
}

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

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

type RPCWriter struct {
	RemoteAddr string
	// contains filtered or unexported fields
}

type Reader interface {
	/**
	 * Bridge of tunnel reader and aggregater(replayer)
	 *
	 */
	Link(aggregate []Replayer) error
}

type ReaderFactory struct {
	Name string
}

type Replayer interface {
	/**
	 * Replay oplog entry with batched Oplog
	 *
	 */
	Sync(message *TMessage, completion func()) int64

	/**
	 * Ack offset value
	 *
	 */
	GetAcked() int64
}

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

type TCPWriter struct {
	RemoteAddr string
	// contains filtered or unexported fields
}

type TMessage struct {
	Checksum uint32
	Tag      uint32
	Shard    uint32
	Compress uint32
	RawLogs  [][]byte
}

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

type TunnelRPC struct {
}

type WMessage struct {
	*TMessage                      // whole raw log
	ParsedLogs []*oplog.PartialLog // parsed log
}

type Writer interface {
	/**
	 * Indicate weather this tunnel cares about ACK feedback value.
	 * Like RPC_TUNNEL (ack required is true), it's asynchronous and
	 * needs peer receiver has completely consumed the log entries
	 * and we can drop the reserved log entries only if the log entry
	 * ACK is confirmed
	 */
	AckRequired() bool

	/**
	 * prepare stage of the tunnel such as create the network connection or initialize
	 * something etc before the Send() invocation.
	 * return true on successful or false on failed
	 */
	Prepare() bool

	/**
	 * write the real tunnel message to tunnel.
	 *
	 * return the right ACK offset value with positive number. if AckRequired is set
	 * this ACk offset is used to purge buffered oplogs. Otherwise upper layer use
	 * the max oplog ts as ACK offset and discard the returned value (ACK offset).
	 * error on returning a negative number
	 */
	Send(message *WMessage) int64

	/**
	 * whether need parsed log or raw log
	 */
	ParsedLogsRequired() bool

	/*
	 * tunnel name
	 */
	Name() string
}

type WriterFactory struct {
	Name string
}