Versions in this module Expand all Collapse all v0 v0.1.1 Oct 24, 2023 v0.1.0 Oct 23, 2023 Changes in this version + type Destination interface + Error func() error + Write func(context.Context, <-chan *api.Record) <-chan *api.RecordStatus + type Error struct + 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 (e *Error) Unwrap() error + func (err *Error) IsDataError() bool + func (err *Error) IsDatabaseError() bool + func (err *Error) IsModelError() bool + type Factory interface + Build func(ctx context.Context, m *Model) (Graph, error) + Close func(ctx context.Context) error + type Filter struct + Key string + Operator FilterOperator + Value interface{} + type FilterOperator string + const EqualFilterOperator + const GreaterThanFilterOperator + const InOperator + const NotInOperator + type Graph interface + Destination func() Destination + Source func(peer string, filters ...Filter) Source + type Model struct + ChildKey string + Children []Model + Filters []string + IsSet bool + Name string + Table Table + type Source interface + Error func() error + Fetch func(ctx context.Context) <-chan *api.Record + SetStatus func(context.Context, ...*api.RecordStatus) error + type Table struct + KeyField string + Name string + PriorityField string + SequenceField string + VersionField string
Go to main page