metadata

Documentation

Index

• Variables
• type Config
• type Metadata
  • func NewMetadata(cfg Config, metadataRepo models.IMetadata, events models.IEvent, ...) (*Metadata, error)
  • func (metadata *Metadata) AttachTo(name string, input *modules.Input) error
  • func (metadata *Metadata) Close() error
  • func (metadata *Metadata) Input(name string) (*modules.Input, error)
  • func (metadata *Metadata) Name() string
  • func (metadata *Metadata) Output(name string) (*modules.Output, error)
  • func (metadata *Metadata) Start(ctx context.Context)

Variables

var (
	OutputMetadata = "metadata"
)

output name

Types

type Config

type Config struct {
	SourceType   sources.Type              `yaml:"source_type" validate:"required,oneof=fs sourcify"`
	ThreadsCount int                       `yaml:"threads_count" validate:"omitempty,min=1"`
	VM           *vm.Config                `yaml:"vm"`
	Sourcify     *sources.SourcifyConfig   `yaml:"sourcify"`
	FS           *sources.FileSystemConfig `yaml:"fs"`
}

Config -

type Metadata

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

Metadata -

func NewMetadata

func NewMetadata(
	cfg Config,
	metadataRepo models.IMetadata,
	events models.IEvent,
	methods models.IMethod,
	transactable storage.Transactable,
) (*Metadata, error)

NewMetadata -

func (*Metadata) AttachTo

func (metadata *Metadata) AttachTo(name string, input *modules.Input) error

AttachTo -

func (*Metadata) Close

func (metadata *Metadata) Close() error

Close -

func (*Metadata) Input

func (metadata *Metadata) Input(name string) (*modules.Input, error)

Input -

func (*Metadata) Name

func (metadata *Metadata) Name() string

Name -

func (*Metadata) Output

func (metadata *Metadata) Output(name string) (*modules.Output, error)

Output -

func (*Metadata) Start

func (metadata *Metadata) Start(ctx context.Context)

Start -