manifest

type Binary struct {
	File                string            `yaml:"file,omitempty"`
	Type                string            `yaml:"type,omitempty"`
	Native              string            `yaml:"native,omitempty"`
	Content             []byte            `yaml:"-"`
	Entrypoint          string            `yaml:"entrypoint,omitempty"`
	ProtoPackageMapping map[string]string `yaml:"protoPackageMapping,omitempty"`
	Build               string            `yaml:"build,omitempty"`
}

type BlockFilter struct {
	Module string           `yaml:"module,omitempty"`
	Query  BlockFilterQuery `yaml:"query,omitempty"`
}

type BlockFilterQuery struct {
	String string `yaml:"string,omitempty"`
	Params bool   `yaml:"params,omitempty"`
}

type BufImport struct {
	LocalPath string   `yaml:"localPath,omitempty"`
	Module    string   `yaml:"module"`
	Version   string   `yaml:"version"`
	Symbols   []string `yaml:"symbols"`
}

type Input struct {
	Source string `yaml:"source,omitempty"`
	Store  string `yaml:"store,omitempty"`
	Map    string `yaml:"map,omitempty"`
	Params string `yaml:"params,omitempty"`

	Mode string `yaml:"mode,omitempty"`
}

type Manifest struct {
	SpecVersion  string                    `yaml:"specVersion,omitempty"` // check that it equals v0.1.0
	Package      PackageMeta               `yaml:"package,omitempty"`
	Protobuf     Protobuf                  `yaml:"protobuf,omitempty"`
	Imports      mapSlice                  `yaml:"imports,omitempty"`
	Binaries     map[string]Binary         `yaml:"binaries,omitempty"`
	Modules      []*Module                 `yaml:"modules,omitempty"`
	Params       map[string]string         `yaml:"params,omitempty"`
	BlockFilters map[string]string         `yaml:"blockFilters,omitempty"`
	Network      string                    `yaml:"network,omitempty"`
	Networks     map[string]*NetworkParams `yaml:"networks,omitempty"`
	Sink         *Sink                     `yaml:"sink,omitempty"`

	Graph   *ModuleGraph `yaml:"-"`
	Workdir string       `yaml:"-"`
}

type Module struct {
	Name         string       `yaml:"name,omitempty"`
	Doc          string       `yaml:"doc,omitempty"`
	Kind         string       `yaml:"kind,omitempty"`
	InitialBlock *uint64      `yaml:"initialBlock,omitempty"`
	BlockFilter  *BlockFilter `yaml:"blockFilter,omitempty"`

	UpdatePolicy string `yaml:"updatePolicy,omitempty"`
	ValueType    string `yaml:"valueType,omitempty"`
	Binary       string `yaml:"binary,omitempty"`

	Inputs []*Input     `yaml:"inputs,omitempty"`
	Output StreamOutput `yaml:"output,omitempty"`
	Use    string       `yaml:"use,omitempty"`
}

type ModuleDescriptor struct {
	// Either or
	StoreValueType string
	MapOutputType  string

	ProtoMessageType  string
	MessageDescriptor *desc.MessageDescriptor
}

type ModuleGraph struct {
	*graph.Mutable
	// contains filtered or unexported fields
}

type ModuleHash []byte

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

type ModuleMarshaler []*pbsubstreams.Module

type NetworkParams struct {
	InitialBlocks map[string]uint64 `yaml:"initialBlock,omitempty" json:"initialBlock,omitempty"`
	Params        map[string]string `yaml:"params,omitempty" json:"params,omitempty"`
}

type Option func(r *Reader) *Reader

type PackageBundle struct {
	Package      *pbsubstreams.Package
	Manifest     *Manifest
	ManifestPath string
	Graph        *ModuleGraph
}

type PackageMeta struct {
	Name        string `yaml:"name,omitempty"`
	Version     string `yaml:"version,omitempty"` // Semver for package authors
	URL         string `yaml:"url,omitempty"`
	Doc         string `yaml:"doc,omitempty"`
	Description string `yaml:"description,omitempty"`
	Image       string `yaml:"image,omitempty"`
}

type Protobuf struct {
	DescriptorSets []*BufImport `yaml:"descriptorSets,omitempty"`
	Files          []string     `yaml:"files,omitempty"`
	ImportPaths    []string     `yaml:"importPaths,omitempty"`
	ExcludePaths   []string     `yaml:"excludePaths,omitempty"`
}

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

type ReaderValidation struct {
	SkipSourceCodeImportValidation bool
	SkipModuleOutputTypeValidation bool
	SkipPackageValidation          bool
}

type Sink struct {
	Type   string      `yaml:"type,omitempty"`
	Module string      `yaml:"module,omitempty"`
	Config interface{} `yaml:"config,omitempty"`
}

type StreamOutput struct {
	// For 'map'
	Type string `yaml:"type,omitempty"`
}