streaming

type DataflowCfg struct {
	JobName            string
	Location           string
	HostProjectId      string
	Network            string
	Subnetwork         string
	DbNameToShardIdMap map[string]string
}

type DatastreamCfg struct {
	StreamId                    string
	StreamLocation              string
	StreamDisplayName           string
	SourceConnectionConfig      SrcConnCfg
	DestinationConnectionConfig DstConnCfg
	Properties                  string
	// contains filtered or unexported fields
}

type DstConnCfg struct {
	Name     string
	Location string
	Prefix   string
}

type SrcConnCfg struct {
	Name     string
	Location string
}

type StreamingCfg struct {
	DatastreamCfg DatastreamCfg
	DataflowCfg   DataflowCfg
	TmpDir        string
	DataShardId   string
}