factable

type Aggregate interface{}

type Combiner struct {
	Schema
	// contains filtered or unexported fields
}

type DimTag uint64

type DimensionSpec struct {
	// Short, unique name of the Dimension.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Type of the Dimension. Immutable.
	Type DimensionType `protobuf:"varint,2,opt,name=type,proto3,enum=factable.DimensionType" json:"type,omitempty"`
	// Longer, free-form description of the Dimension.
	Desc string `protobuf:"bytes,3,opt,name=desc,proto3" json:"desc,omitempty"`
	// Unique tag of the dimension.
	Tag DimTag `protobuf:"varint,4,opt,name=tag,proto3,casttype=DimTag" json:"tag,omitempty"`
}

type DimensionType int32

type ExecuteQueryRequest struct {
	// Header attached by a proxy-ing peer. Not directly set by clients.
	Header *protocol.Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Shard to query. Set iff |header| is also set
	// TODO (chris): if this is go.gazette.dev/core/consumer.ShardID instead of a string
	// the .pb.go file is not valid.
	Shard go_gazette_dev_core_consumer_protocol.ShardID `protobuf:"bytes,2,opt,name=shard,proto3,casttype=go.gazette.dev/core/consumer/protocol.ShardID" json:"shard,omitempty"`
	// Query specification.
	Query ResolvedQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query"`
}

type ExtractFns struct {
	// NewMessage supplies a user Message instance for the input JournalSpec.
	NewMessage func(*pb.JournalSpec) (message.Message, error)
	// Mapping of decoded messages to zero or more RelationRows.
	Mapping map[MapTag]func(message.Envelope) []RelationRow
	// Dimension extractors for each DimensionType.
	// Registered tags must be non-overlapping.
	Int    map[DimTag]func(r RelationRow) int64
	Float  map[DimTag]func(r RelationRow) float64
	String map[DimTag]func(r RelationRow) string
	Time   map[DimTag]func(r RelationRow) time.Time
}

type Field interface{}

type GetSchemaResponse struct {
	// Name of this Factable release instance.
	Instance string `protobuf:"bytes,3,opt,name=instance,proto3" json:"instance,omitempty"`
	// ModRevision of the current SchemaSpec
	ModRevision int64 `protobuf:"varint,1,opt,name=mod_revision,json=modRevision,proto3" json:"mod_revision,omitempty"`
	// Current value of the SchemaSpec. Zero-valued if |mod_revision| is zero.
	Spec SchemaSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec"`
	// LabelSelector over Extractor output / VTable input "delta" partitions.
	DeltaPartitions protocol.LabelSelector `protobuf:"bytes,4,opt,name=delta_partitions,json=deltaPartitions,proto3" json:"delta_partitions"`
}

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

type KVIterator interface {
	// Next returns the next |key| and |value| of the KVIterator. It returns
	// KVIteratorDone if no items remain in the sequence, or any encountered
	// error (which also invalidates the iterator). The returned |key| and
	// |value| may be retained only until the next call to Next.
	Next() (key, value []byte, err error)
	// Close the KVIterator, releasing associated resources.
	Close() error
}

type KVIteratorSeeker interface {
	Seek(key []byte)
}

type MVTag uint64

type MapTag uint64

type MappingSpec struct {
	// Short, unique name of the Mapping.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Longer, free-form description of the Mapping.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
	// Unique tag of the Mapping.
	Tag MapTag `protobuf:"varint,3,opt,name=tag,proto3,casttype=MapTag" json:"tag,omitempty"`
}

type MaterializedViewSpec struct {
	// Short, unique name of the MaterializedView.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Relation which this view materializes.
	Relation string `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
	// View materialized by the MaterializedView.
	View ViewSpec `protobuf:"bytes,3,opt,name=view,proto3" json:"view"`
	// Longer, free-form description of the MaterializedView.
	Desc      string                          `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`
	Retention *MaterializedViewSpec_Retention `protobuf:"bytes,5,opt,name=retention,proto3" json:"retention,omitempty"`
	// Unique tag of the MaterializedView.
	Tag MVTag `protobuf:"varint,6,opt,name=tag,proto3,casttype=MVTag" json:"tag,omitempty"`
	// Resolved RelTag. Immutable.
	RelTag RelTag `protobuf:"varint,7,opt,name=rel_tag,json=relTag,proto3,casttype=RelTag" json:"rel_tag,omitempty" yaml:",omitempty"`
	// Resolution of the View. Immutable.
	ResolvedView ResolvedView `protobuf:"bytes,8,opt,name=resolved_view,json=resolvedView,proto3" json:"resolved_view" yaml:",omitempty"`
}

type MaterializedViewSpec_Retention struct {
	// Duration after which a row is eligible for removal.
	RemoveAfter time.Duration `protobuf:"bytes,1,opt,name=remove_after,json=removeAfter,proto3,stdduration" json:"remove_after"`
	// Dimension, which must be part of the MaterializedView and of type
	// Timestamp, to which |remove_after| is added to determine the effective
	// removal horizon.
	RelativeTo string `protobuf:"bytes,2,opt,name=relative_to,json=relativeTo,proto3" json:"relative_to,omitempty"`
	// Resolved DimTag of |relative_to|.
	RelativeToTag DimTag `` /* 137-byte string literal not displayed */
}

type MetTag uint64

type MetricSpec struct {
	// Short, unique name of the Metric.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Dimension from which the Metric is extracted.
	Dimension string `protobuf:"bytes,2,opt,name=dimension,proto3" json:"dimension,omitempty"`
	// Type of the Metric. Immutable.
	Type MetricType `protobuf:"varint,3,opt,name=type,proto3,enum=factable.MetricType" json:"type,omitempty"`
	// Longer, free-form description of the Metric.
	Desc string `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`
	// Unique tag of the Metric.
	Tag MetTag `protobuf:"varint,5,opt,name=tag,proto3,casttype=MetTag" json:"tag,omitempty"`
	// Resolved DimTag of |dimension|. Immutable.
	DimTag DimTag `protobuf:"varint,6,opt,name=dim_tag,json=dimTag,proto3,casttype=DimTag" json:"dim_tag,omitempty" yaml:",omitempty"`
}

type MetricType int32

type QueryClient interface {
	// ResolveQuery maps a QuerySpec into a validated ResolvedQuery,
	// under the current server schema.
	ResolveQuery(ctx context.Context, in *QuerySpec, opts ...grpc.CallOption) (*ResolvedQuery, error)
	// ExecuteResolvedQuery against one or all Shards.
	ExecuteQuery(ctx context.Context, in *ExecuteQueryRequest, opts ...grpc.CallOption) (Query_ExecuteQueryClient, error)
}

type QueryResponse struct {
	// Response header. Set on the first QueryResponse only.
	Header *protocol.Header `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	// Encoded table rows.
	Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"`
}

type QueryServer interface {
	// ResolveQuery maps a QuerySpec into a validated ResolvedQuery,
	// under the current server schema.
	ResolveQuery(context.Context, *QuerySpec) (*ResolvedQuery, error)
	// ExecuteResolvedQuery against one or all Shards.
	ExecuteQuery(*ExecuteQueryRequest, Query_ExecuteQueryServer) error
}

type QuerySpec struct {
	// MaterializedView to query.
	MaterializedView string `protobuf:"bytes,2,opt,name=materialized_view,json=materializedView,proto3" json:"materialized_view,omitempty"`
	// View of the Query result.
	//
	// Dimensions of the Relation which should be grouped over and returned with
	// the Query result set. Other Dimensions included in the MaterializedView but
	// not included in the Query Shape are aggregated across.
	//
	// Where possible, use a strict ordered prefix of underlying MaterializedView
	// Dimensions. This is much more efficient to evaluate, as grouping can
	// utilize the natural index order, and no further recombining or sorting is
	// required. When using a prefix, the Query result set is incrementally
	// streamed as it is evaluated, and even extremely large result sets can be
	// queried efficiently.
	//
	// If Dimensions are not a strict prefix, the Query evaluator must perform
	// recombination and sorting steps, and results will be sent only after
	// all underlying view rows have been read. Implementations may also limit
	// the size of the result sets they will buffer, returning an error for
	// Queries which exceed it.
	View    ViewSpec           `protobuf:"bytes,3,opt,name=view,proto3" json:"view"`
	Filters []QuerySpec_Filter `protobuf:"bytes,4,rep,name=filters,proto3" json:"filters"`
}

type QuerySpec_Filter struct {
	// Dimension to which the Filter is applied.
	Dimension string                    `protobuf:"bytes,1,opt,name=dimension,proto3" json:"dimension,omitempty"`
	Ints      []QuerySpec_Filter_Int    `protobuf:"bytes,2,rep,name=ints,proto3" json:"ints"`
	Floats    []QuerySpec_Filter_Float  `protobuf:"bytes,3,rep,name=floats,proto3" json:"floats"`
	Strings   []QuerySpec_Filter_String `protobuf:"bytes,4,rep,name=strings,proto3" json:"strings"`
	Times     []QuerySpec_Filter_Time   `protobuf:"bytes,5,rep,name=times,proto3" json:"times"`
}

type QuerySpec_Filter_Float struct {
	Begin float64 `protobuf:"fixed64,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   float64 `protobuf:"fixed64,2,opt,name=end,proto3" json:"end,omitempty"`
}

type QuerySpec_Filter_Int struct {
	Begin int64 `protobuf:"varint,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   int64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"`
}

type QuerySpec_Filter_String struct {
	Begin string `protobuf:"bytes,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   string `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
}

type QuerySpec_Filter_Time struct {
	Begin         time.Time     `protobuf:"bytes,1,opt,name=begin,proto3,stdtime" json:"begin"`
	End           time.Time     `protobuf:"bytes,2,opt,name=end,proto3,stdtime" json:"end"`
	RelativeBegin time.Duration `protobuf:"bytes,3,opt,name=relative_begin,json=relativeBegin,proto3,stdduration" json:"relative_begin"`
	RelativeEnd   time.Duration `protobuf:"bytes,4,opt,name=relative_end,json=relativeEnd,proto3,stdduration" json:"relative_end"`
}

type Query_ExecuteQueryClient interface {
	Recv() (*QueryResponse, error)
	grpc.ClientStream
}

type Query_ExecuteQueryServer interface {
	Send(*QueryResponse) error
	grpc.ServerStream
}

type RelTag uint64

type RelationRow []interface{}

type RelationSpec struct {
	// Short, unique name of the Relation.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// LabelSelector identifies journals which, taken together, compose the "rows" of the Relation.
	Selector protocol.LabelSelector `protobuf:"bytes,2,opt,name=selector,proto3" json:"selector"`
	// Mapping which transforms journal events into Relation rows.
	Mapping string `protobuf:"bytes,3,opt,name=mapping,proto3" json:"mapping,omitempty"`
	// Dimensions of the Relation. Dimensions may be added and removed over time,
	// but all Dimensions or derived Metrics of current MaterializedViewSpecs must
	// refer to current Dimensions of the RelationSpec.
	Dimensions []string `protobuf:"bytes,4,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Longer, free-form description of the Relation.
	Desc string `protobuf:"bytes,5,opt,name=desc,proto3" json:"desc,omitempty"`
	// Unique tag of the Relation.
	Tag RelTag `protobuf:"varint,6,opt,name=tag,proto3,casttype=RelTag" json:"tag,omitempty"`
	// Resolved MapTag of |mapping|. Immutable.
	MapTag MapTag `protobuf:"varint,7,opt,name=map_tag,json=mapTag,proto3,casttype=MapTag" json:"map_tag,omitempty" yaml:",omitempty"`
	// Resolved DimTags of |dimensions|. Immutable.
	DimTags []DimTag `protobuf:"varint,8,rep,packed,name=dim_tags,json=dimTags,proto3,casttype=DimTag" json:"dim_tags,omitempty" yaml:",omitempty"`
}

type ReservedMVTagSpec struct {
	// Reserved tag in the same space as MaterializedView.
	Tag MVTag `protobuf:"varint,1,opt,name=tag,proto3,casttype=MVTag" json:"tag,omitempty"`
	// Longer, free-form description of the reserved MVTag.
	Desc string `protobuf:"bytes,2,opt,name=desc,proto3" json:"desc,omitempty"`
}

type ResolvedQuery struct {
	// Tag of the MaterializedViewSpec to be queried.
	MvTag MVTag `protobuf:"varint,1,opt,name=mv_tag,json=mvTag,proto3,casttype=MVTag" json:"mv_tag,omitempty"`
	// Shape of the query result.
	View    ResolvedView           `protobuf:"bytes,2,opt,name=view,proto3" json:"view"`
	Filters []ResolvedQuery_Filter `protobuf:"bytes,3,rep,name=filters,proto3" json:"filters"`
}

type ResolvedQuery_Filter struct {
	// Dimension to which the Filter is applied.
	DimTag DimTag                       `protobuf:"varint,1,opt,name=dim_tag,json=dimTag,proto3,casttype=DimTag" json:"dim_tag,omitempty"`
	Ranges []ResolvedQuery_Filter_Range `protobuf:"bytes,2,rep,name=ranges,proto3" json:"ranges"`
}

type ResolvedQuery_Filter_Range struct {
	Begin []byte `protobuf:"bytes,1,opt,name=begin,proto3" json:"begin,omitempty"`
	End   []byte `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
}

type ResolvedView struct {
	// Resolved DimTags of ViewSpec Dimensions.
	DimTags []DimTag `protobuf:"varint,1,rep,packed,name=dim_tags,json=dimTags,proto3,casttype=DimTag" json:"dim_tags,omitempty"`
	// Resolved MetTags of ViewSpec Metrics.
	MetTags []MetTag `protobuf:"varint,2,rep,packed,name=met_tags,json=metTags,proto3,casttype=MetTag" json:"met_tags,omitempty"`
}

type Schema struct {
	Extract ExtractFns
	Spec    SchemaSpec

	Mappings       map[MapTag]MappingSpec
	Dimensions     map[DimTag]DimensionSpec
	Metrics        map[MetTag]MetricSpec
	Relations      map[RelTag]RelationSpec
	ReservedMVTags map[MVTag]struct{}
	Views          map[MVTag]MaterializedViewSpec

	MapTags map[string]MapTag
	DimTags map[string]DimTag
	MetTags map[string]MetTag
	RelTags map[string]RelTag
	MVTags  map[string]MVTag
}

type SchemaClient interface {
	// GetSchema retrieves the current SchemaSpec.
	GetSchema(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	// UpdateSchema updates the SchemaSpec to a new value.
	UpdateSchema(ctx context.Context, in *UpdateSchemaRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

type SchemaServer interface {
	// GetSchema retrieves the current SchemaSpec.
	GetSchema(context.Context, *empty.Empty) (*GetSchemaResponse, error)
	// UpdateSchema updates the SchemaSpec to a new value.
	UpdateSchema(context.Context, *UpdateSchemaRequest) (*empty.Empty, error)
}

type SchemaSpec struct {
	Mappings         []MappingSpec          `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings"`
	Dimensions       []DimensionSpec        `protobuf:"bytes,2,rep,name=dimensions,proto3" json:"dimensions"`
	Metrics          []MetricSpec           `protobuf:"bytes,3,rep,name=metrics,proto3" json:"metrics"`
	Relations        []RelationSpec         `protobuf:"bytes,4,rep,name=relations,proto3" json:"relations"`
	Views            []MaterializedViewSpec `protobuf:"bytes,5,rep,name=views,proto3" json:"views"`
	ReservedViewTags []ReservedMVTagSpec    `protobuf:"bytes,6,rep,name=reserved_view_tags,json=reservedViewTags,proto3" json:"reserved_view_tags"`
}

type UnimplementedQueryServer struct {
}

type UnimplementedSchemaServer struct {
}

type UpdateSchemaRequest struct {
	// Expected Name of the Factable release instance.
	ExpectInstance string `protobuf:"bytes,1,opt,name=expect_instance,json=expectInstance,proto3" json:"expect_instance,omitempty"`
	// Expected ModRevision of the current SchemaSpec. Zero if the SchemaSpec
	// is being created for the first time.
	ExpectModRevision int64 `protobuf:"varint,2,opt,name=expect_mod_revision,json=expectModRevision,proto3" json:"expect_mod_revision,omitempty"`
	// Updated SchemaSpec to apply.
	Update SchemaSpec `protobuf:"bytes,3,opt,name=update,proto3" json:"update"`
}

type ViewSpec struct {
	// Ordered Dimensions summarized by the ViewSpec.
	Dimensions []string `protobuf:"bytes,1,rep,name=dimensions,proto3" json:"dimensions,omitempty"`
	// Ordered Metrics aggregated by the ViewSpec.
	Metrics []string `protobuf:"bytes,2,rep,name=metrics,proto3" json:"metrics,omitempty"`
}