aggregator

type AggregatorClient interface {
	// Detect language of extracted texts
	RunLanguageDetection(ctx context.Context, in *RunLanguageDetectionRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Aggregate data from veidemann to maalfrid
	RunAggregation(ctx context.Context, in *RunAggregationRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	// Synchronize entities from veidemann to maalfrid
	SyncEntities(ctx context.Context, in *SyncEntitiesRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	FilterAggregate(ctx context.Context, in *FilterAggregateRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

type AggregatorServer interface {
	// Detect language of extracted texts
	RunLanguageDetection(context.Context, *RunLanguageDetectionRequest) (*empty.Empty, error)
	// Aggregate data from veidemann to maalfrid
	RunAggregation(context.Context, *RunAggregationRequest) (*empty.Empty, error)
	// Synchronize entities from veidemann to maalfrid
	SyncEntities(context.Context, *SyncEntitiesRequest) (*empty.Empty, error)
	FilterAggregate(context.Context, *FilterAggregateRequest) (*empty.Empty, error)
}

type FilterAggregateRequest struct {
	JobExecutionId       string   `protobuf:"bytes,1,opt,name=job_execution_id,json=jobExecutionId" json:"job_execution_id,omitempty"`
	SeedId               string   `protobuf:"bytes,2,opt,name=seed_id,json=seedId" json:"seed_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type Label struct {
	Key                  string   `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RunAggregationRequest struct {
	JobExecutionId       string   `protobuf:"bytes,1,opt,name=job_execution_id,json=jobExecutionId" json:"job_execution_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type RunLanguageDetectionRequest struct {
	// If language detection should process extracted texts already processed
	DetectAll            bool     `protobuf:"varint,1,opt,name=detect_all,json=detectAll" json:"detect_all,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type SyncEntitiesRequest struct {
	// if set then only entities with a matching name will be synchronized
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	// if set then only entities labeled with any of the labels will be synchronized
	Labels               []*Label `protobuf:"bytes,2,rep,name=labels" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}