ldbserver

type DBServer interface {
	Close()
	// contains filtered or unexported methods
}

type DeadLineListener interface {
	SetDeadline(t time.Time) (err error)
}

type JsonProtobufTransportFactory struct{ Mt MarshalingType }

type MarshalingType int

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

type TransportBody struct {
	Checksum         *uint32 `protobuf:"varint,1,req,name=checksum" json:"checksum,omitempty"`
	Data             []byte  `protobuf:"bytes,2,opt,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

type TransportRequest struct {
	Id               []byte                    `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Command          *TransportRequest_Command `protobuf:"varint,2,req,name=command,enum=ldbserver.TransportRequest_Command" json:"command,omitempty"`
	Body             *TransportBody            `protobuf:"bytes,3,opt,name=body" json:"body,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

type TransportRequest_Command int32

type TransportResponse struct {
	Id               []byte                    `protobuf:"bytes,1,req,name=id" json:"id,omitempty"`
	Status           *TransportResponse_Status `protobuf:"varint,2,req,name=status,enum=ldbserver.TransportResponse_Status" json:"status,omitempty"`
	Body             *TransportBody            `protobuf:"bytes,3,opt,name=body" json:"body,omitempty"`
	XXX_unrecognized []byte                    `json:"-"`
}

type TransportResponse_Status int32

type Transporter interface {
	GetRequest() (*TransportRequest, error)
	SendResponse(*TransportResponse) error
}

type TransporterFactory interface {
	NewTransporter(r io.Reader, w io.Writer) Transporter
}