package typecheck

import "github.com/influxdata/influxdb/cmd/influx_inspect/type_conflicts"

Index ¶

• type FieldTypes
• func (ft FieldTypes) MarshalText() (text []byte, err error)
• func (ft *FieldTypes) UnmarshalText(text []byte) error
• type MergeFilesCommand
• func NewMergeFilesCommand() *MergeFilesCommand
• func (rc *MergeFilesCommand) Run(args ...string) error
• type Schema
• func NewSchema() Schema
• func SchemaFromFile(filename string) (Schema, error)
• func (s Schema) AddField(database, retention, measurement, field, dataType string)
• func (s Schema) AddFormattedField(field string, dataType string)
• func (s Schema) Conflicts() Schema
• func (s Schema) Decode(r io.Reader) error
• func (s Schema) Encode(w io.Writer) error
• func (s Schema) Merge(schema Schema)
• func (s Schema) WriteConflictsFile(filename string) error
• func (s Schema) WriteSchemaFile(filename string) error
• type TypeConflictChecker
• func NewTypeConflictCheckerCommand() *TypeConflictChecker
• func (tc *TypeConflictChecker) Run(args ...string) error
• type UniqueField
• func (uf *UniqueField) String() string

Types ¶

type FieldTypes ¶

type FieldTypes map[string]struct{}

func (FieldTypes) MarshalText ¶

func (ft FieldTypes) MarshalText() (text []byte, err error)

func (*FieldTypes) UnmarshalText ¶

func (ft *FieldTypes) UnmarshalText(text []byte) error

type MergeFilesCommand ¶

type MergeFilesCommand struct {
	OutputFile    string
	ConflictsFile string
}

func NewMergeFilesCommand ¶

func NewMergeFilesCommand() *MergeFilesCommand

func (*MergeFilesCommand) Run ¶

func (rc *MergeFilesCommand) Run(args ...string) error

type Schema ¶

type Schema map[string]FieldTypes

func NewSchema ¶

func NewSchema() Schema

func SchemaFromFile ¶

func SchemaFromFile(filename string) (Schema, error)

func (Schema) AddField ¶

func (s Schema) AddField(database, retention, measurement, field, dataType string)

func (Schema) AddFormattedField ¶

func (s Schema) AddFormattedField(field string, dataType string)

func (Schema) Conflicts ¶

func (s Schema) Conflicts() Schema

func (Schema) Decode ¶

func (s Schema) Decode(r io.Reader) error

func (Schema) Encode ¶

func (s Schema) Encode(w io.Writer) error

func (Schema) Merge ¶

func (s Schema) Merge(schema Schema)

func (Schema) WriteConflictsFile ¶

func (s Schema) WriteConflictsFile(filename string) error

func (Schema) WriteSchemaFile ¶

func (s Schema) WriteSchemaFile(filename string) error

type TypeConflictChecker ¶

type TypeConflictChecker struct {
	Path          string
	SchemaFile    string
	ConflictsFile string
}

func NewTypeConflictCheckerCommand ¶

func NewTypeConflictCheckerCommand() *TypeConflictChecker

func (*TypeConflictChecker) Run ¶

func (tc *TypeConflictChecker) Run(args ...string) error

type UniqueField ¶

type UniqueField struct {
	Database    string `json:"database"`
	Retention   string `json:"retention"`
	Measurement string `json:"measurement"`
	Field       string `json:"field"`
}

func (*UniqueField) String ¶

func (uf *UniqueField) String() string

Source Files ¶

resolve_conflicts.go schema.go type_conflicts.go