graph

Documentation

Index

• type Destination
• type Error
  • func MalformedDataError() Error
  • func NewDataError(msg string, err ...error) *Error
  • func NewDatabaseError(err error) *Error
  • func NewModelError(err error) *Error
  • func NoDataError() Error
  • func UnexpectedRowCountError() Error
  • func (err *Error) IsDataError() bool
  • func (err *Error) IsDatabaseError() bool
  • func (err *Error) IsModelError() bool
  • func (e *Error) Unwrap() error
• type Factory
• type Filter
• type FilterOperator
• type Graph
• type Model
• type Source
• type Table

Types

type Destination

type Destination interface {
	Write(context.Context, <-chan *api.Record) <-chan *api.RecordStatus
	Error() error
}

type Error

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

func MalformedDataError

func MalformedDataError() Error

func NewDataError

func NewDataError(msg string, err ...error) *Error

func NewDatabaseError

func NewDatabaseError(err error) *Error

func NewModelError

func NewModelError(err error) *Error

func NoDataError

func NoDataError() Error

func UnexpectedRowCountError

func UnexpectedRowCountError() Error

func (*Error) IsDataError

func (err *Error) IsDataError() bool

func (*Error) IsDatabaseError

func (err *Error) IsDatabaseError() bool

func (*Error) IsModelError

func (err *Error) IsModelError() bool

func (*Error) Unwrap

func (e *Error) Unwrap() error

type Factory

type Factory interface {
	Build(ctx context.Context, m *Model) (Graph, error)
	Close(ctx context.Context) error
}

type Filter

type Filter struct {
	Key      string
	Operator FilterOperator
	Value    interface{}
}

type FilterOperator

type FilterOperator string

const (
	GreaterThanFilterOperator FilterOperator = "GreaterThan"
	EqualFilterOperator       FilterOperator = "Equal"
	InOperator                FilterOperator = "In"
	NotInOperator             FilterOperator = "NotIn"
)

type Graph

type Graph interface {
	Source(peer string, filters ...Filter) Source
	Destination() Destination
}

type Model

type Model struct {
	Name     string
	Table    Table
	IsSet    bool
	ChildKey string
	Children []Model
	Filters  []string
}

type Source

type Source interface {
	Fetch(ctx context.Context) <-chan *api.Record
	Error() error
	SetStatus(context.Context, ...*api.RecordStatus) error
}

type Table

type Table struct {
	Name          string
	KeyField      string
	SequenceField string
	PriorityField string
	VersionField  string
}