writer

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

type DBCommand struct {
	PipelineID uint64
	Sequence   uint64
	Reference  interface{}
	Record     *gravity_sdk_types_record.Record
	QueryStr   string
	Args       map[string]interface{}
	Tables     []string
}

type Field struct {
	Type  string      `json:"type"`
	Field interface{} `json:"field"`
}

type JsonData struct {
	Schema   Schema                 `json:"schema"`
	Playload map[string]interface{} `json:"playload"`
}

type Schema struct {
	Method string  `json:"method"`
	Event  string  `json:"event"`
	Table  string  `json:"table"`
	Type   string  `json:"type"`
	Fields []Field `json:"fields"`
}

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