grpc

type Config struct {
	SourceID      string                 `json:"source_id" yaml:"source_id"`
	Address       string                 `json:"address" yaml:"address"`
	Method        string                 `json:"method" yaml:"method"` // full method: /package.Service/Method
	TLS           bool                   `json:"tls" yaml:"tls"`
	ServerName    string                 `json:"server_name" yaml:"server_name"`
	Headers       map[string]string      `json:"headers" yaml:"headers"`
	Request       map[string]interface{} `json:"request" yaml:"request"`
	SchemaName    string                 `json:"schema_name" yaml:"schema_name"`
	SchemaVersion string                 `json:"schema_version" yaml:"schema_version"`
	FactTypeField string                 `json:"fact_type_field" yaml:"fact_type_field"`
	Timeout       time.Duration          `json:"timeout" yaml:"timeout"`
	BufferSize    int                    `json:"buffer_size" yaml:"buffer_size"`
}

type Factory struct{}

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