Documentation ¶
Index ¶
- func RegisterAggregatorServer(s *grpc.Server, srv AggregatorServer)
- type AggregatorClient
- type AggregatorServer
- type FilterAggregateRequest
- func (*FilterAggregateRequest) Descriptor() ([]byte, []int)
- func (m *FilterAggregateRequest) GetJobExecutionId() string
- func (m *FilterAggregateRequest) GetSeedId() string
- func (*FilterAggregateRequest) ProtoMessage()
- func (m *FilterAggregateRequest) Reset()
- func (m *FilterAggregateRequest) String() string
- func (m *FilterAggregateRequest) XXX_DiscardUnknown()
- func (m *FilterAggregateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *FilterAggregateRequest) XXX_Merge(src proto.Message)
- func (m *FilterAggregateRequest) XXX_Size() int
- func (m *FilterAggregateRequest) XXX_Unmarshal(b []byte) error
- type Label
- func (*Label) Descriptor() ([]byte, []int)
- func (m *Label) GetKey() string
- func (m *Label) GetValue() string
- func (*Label) ProtoMessage()
- func (m *Label) Reset()
- func (m *Label) String() string
- func (m *Label) XXX_DiscardUnknown()
- func (m *Label) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Label) XXX_Merge(src proto.Message)
- func (m *Label) XXX_Size() int
- func (m *Label) XXX_Unmarshal(b []byte) error
- type RunAggregationRequest
- func (*RunAggregationRequest) Descriptor() ([]byte, []int)
- func (m *RunAggregationRequest) GetJobExecutionId() string
- func (*RunAggregationRequest) ProtoMessage()
- func (m *RunAggregationRequest) Reset()
- func (m *RunAggregationRequest) String() string
- func (m *RunAggregationRequest) XXX_DiscardUnknown()
- func (m *RunAggregationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RunAggregationRequest) XXX_Merge(src proto.Message)
- func (m *RunAggregationRequest) XXX_Size() int
- func (m *RunAggregationRequest) XXX_Unmarshal(b []byte) error
- type RunLanguageDetectionRequest
- func (*RunLanguageDetectionRequest) Descriptor() ([]byte, []int)
- func (m *RunLanguageDetectionRequest) GetDetectAll() bool
- func (*RunLanguageDetectionRequest) ProtoMessage()
- func (m *RunLanguageDetectionRequest) Reset()
- func (m *RunLanguageDetectionRequest) String() string
- func (m *RunLanguageDetectionRequest) XXX_DiscardUnknown()
- func (m *RunLanguageDetectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RunLanguageDetectionRequest) XXX_Merge(src proto.Message)
- func (m *RunLanguageDetectionRequest) XXX_Size() int
- func (m *RunLanguageDetectionRequest) XXX_Unmarshal(b []byte) error
- type SyncEntitiesRequest
- func (*SyncEntitiesRequest) Descriptor() ([]byte, []int)
- func (m *SyncEntitiesRequest) GetLabels() []*Label
- func (m *SyncEntitiesRequest) GetName() string
- func (*SyncEntitiesRequest) ProtoMessage()
- func (m *SyncEntitiesRequest) Reset()
- func (m *SyncEntitiesRequest) String() string
- func (m *SyncEntitiesRequest) XXX_DiscardUnknown()
- func (m *SyncEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *SyncEntitiesRequest) XXX_Merge(src proto.Message)
- func (m *SyncEntitiesRequest) XXX_Size() int
- func (m *SyncEntitiesRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterAggregatorServer ¶
func RegisterAggregatorServer(s *grpc.Server, srv AggregatorServer)
Types ¶
type AggregatorClient ¶
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) }
func NewAggregatorClient ¶
func NewAggregatorClient(cc *grpc.ClientConn) AggregatorClient
type AggregatorServer ¶
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 ¶
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:"-"` }
func (*FilterAggregateRequest) Descriptor ¶
func (*FilterAggregateRequest) Descriptor() ([]byte, []int)
func (*FilterAggregateRequest) GetJobExecutionId ¶
func (m *FilterAggregateRequest) GetJobExecutionId() string
func (*FilterAggregateRequest) GetSeedId ¶
func (m *FilterAggregateRequest) GetSeedId() string
func (*FilterAggregateRequest) ProtoMessage ¶
func (*FilterAggregateRequest) ProtoMessage()
func (*FilterAggregateRequest) Reset ¶
func (m *FilterAggregateRequest) Reset()
func (*FilterAggregateRequest) String ¶
func (m *FilterAggregateRequest) String() string
func (*FilterAggregateRequest) XXX_DiscardUnknown ¶
func (m *FilterAggregateRequest) XXX_DiscardUnknown()
func (*FilterAggregateRequest) XXX_Marshal ¶
func (m *FilterAggregateRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FilterAggregateRequest) XXX_Merge ¶
func (dst *FilterAggregateRequest) XXX_Merge(src proto.Message)
func (*FilterAggregateRequest) XXX_Size ¶
func (m *FilterAggregateRequest) XXX_Size() int
func (*FilterAggregateRequest) XXX_Unmarshal ¶
func (m *FilterAggregateRequest) XXX_Unmarshal(b []byte) error
type Label ¶
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:"-"` }
func (*Label) Descriptor ¶
func (*Label) ProtoMessage ¶
func (*Label) ProtoMessage()
func (*Label) XXX_DiscardUnknown ¶
func (m *Label) XXX_DiscardUnknown()
func (*Label) XXX_Marshal ¶
func (*Label) XXX_Unmarshal ¶
type RunAggregationRequest ¶
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:"-"` }
func (*RunAggregationRequest) Descriptor ¶
func (*RunAggregationRequest) Descriptor() ([]byte, []int)
func (*RunAggregationRequest) GetJobExecutionId ¶
func (m *RunAggregationRequest) GetJobExecutionId() string
func (*RunAggregationRequest) ProtoMessage ¶
func (*RunAggregationRequest) ProtoMessage()
func (*RunAggregationRequest) Reset ¶
func (m *RunAggregationRequest) Reset()
func (*RunAggregationRequest) String ¶
func (m *RunAggregationRequest) String() string
func (*RunAggregationRequest) XXX_DiscardUnknown ¶
func (m *RunAggregationRequest) XXX_DiscardUnknown()
func (*RunAggregationRequest) XXX_Marshal ¶
func (m *RunAggregationRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunAggregationRequest) XXX_Merge ¶
func (dst *RunAggregationRequest) XXX_Merge(src proto.Message)
func (*RunAggregationRequest) XXX_Size ¶
func (m *RunAggregationRequest) XXX_Size() int
func (*RunAggregationRequest) XXX_Unmarshal ¶
func (m *RunAggregationRequest) XXX_Unmarshal(b []byte) error
type RunLanguageDetectionRequest ¶
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:"-"` }
func (*RunLanguageDetectionRequest) Descriptor ¶
func (*RunLanguageDetectionRequest) Descriptor() ([]byte, []int)
func (*RunLanguageDetectionRequest) GetDetectAll ¶
func (m *RunLanguageDetectionRequest) GetDetectAll() bool
func (*RunLanguageDetectionRequest) ProtoMessage ¶
func (*RunLanguageDetectionRequest) ProtoMessage()
func (*RunLanguageDetectionRequest) Reset ¶
func (m *RunLanguageDetectionRequest) Reset()
func (*RunLanguageDetectionRequest) String ¶
func (m *RunLanguageDetectionRequest) String() string
func (*RunLanguageDetectionRequest) XXX_DiscardUnknown ¶
func (m *RunLanguageDetectionRequest) XXX_DiscardUnknown()
func (*RunLanguageDetectionRequest) XXX_Marshal ¶
func (m *RunLanguageDetectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RunLanguageDetectionRequest) XXX_Merge ¶
func (dst *RunLanguageDetectionRequest) XXX_Merge(src proto.Message)
func (*RunLanguageDetectionRequest) XXX_Size ¶
func (m *RunLanguageDetectionRequest) XXX_Size() int
func (*RunLanguageDetectionRequest) XXX_Unmarshal ¶
func (m *RunLanguageDetectionRequest) XXX_Unmarshal(b []byte) error
type SyncEntitiesRequest ¶
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:"-"` }
func (*SyncEntitiesRequest) Descriptor ¶
func (*SyncEntitiesRequest) Descriptor() ([]byte, []int)
func (*SyncEntitiesRequest) GetLabels ¶
func (m *SyncEntitiesRequest) GetLabels() []*Label
func (*SyncEntitiesRequest) GetName ¶
func (m *SyncEntitiesRequest) GetName() string
func (*SyncEntitiesRequest) ProtoMessage ¶
func (*SyncEntitiesRequest) ProtoMessage()
func (*SyncEntitiesRequest) Reset ¶
func (m *SyncEntitiesRequest) Reset()
func (*SyncEntitiesRequest) String ¶
func (m *SyncEntitiesRequest) String() string
func (*SyncEntitiesRequest) XXX_DiscardUnknown ¶
func (m *SyncEntitiesRequest) XXX_DiscardUnknown()
func (*SyncEntitiesRequest) XXX_Marshal ¶
func (m *SyncEntitiesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*SyncEntitiesRequest) XXX_Merge ¶
func (dst *SyncEntitiesRequest) XXX_Merge(src proto.Message)
func (*SyncEntitiesRequest) XXX_Size ¶
func (m *SyncEntitiesRequest) XXX_Size() int
func (*SyncEntitiesRequest) XXX_Unmarshal ¶
func (m *SyncEntitiesRequest) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.