Documentation ¶
Index ¶
- Variables
- func RegisterIngesterServer(s grpc.ServiceRegistrar, srv IngesterServer)
- type BulkIngestRequest
- func (*BulkIngestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BulkIngestRequest) GetDocumentType() string
- func (x *BulkIngestRequest) GetDocuments() []*Document
- func (x *BulkIngestRequest) GetMergeConfigs() []*MergeConfig
- func (x *BulkIngestRequest) GetUUID() string
- func (*BulkIngestRequest) ProtoMessage()
- func (x *BulkIngestRequest) ProtoReflect() protoreflect.Message
- func (x *BulkIngestRequest) Reset()
- func (x *BulkIngestRequest) String() string
- type BulkIngestResponse
- func (*BulkIngestResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BulkIngestResponse) GetStatus() string
- func (*BulkIngestResponse) ProtoMessage()
- func (x *BulkIngestResponse) ProtoReflect() protoreflect.Message
- func (x *BulkIngestResponse) Reset()
- func (x *BulkIngestResponse) String() string
- type Document
- func (*Document) Descriptor() ([]byte, []int)deprecated
- func (x *Document) GetID() string
- func (x *Document) GetIndex() string
- func (x *Document) GetIndexType() string
- func (x *Document) GetSource() *_struct.Struct
- func (*Document) ProtoMessage()
- func (x *Document) ProtoReflect() protoreflect.Message
- func (x *Document) Reset()
- func (x *Document) String() string
- type FieldMath
- type Group
- func (*Group) Descriptor() ([]byte, []int)deprecated
- func (x *Group) GetCondition() string
- func (x *Group) GetFieldForceUpdate() []string
- func (x *Group) GetFieldKeepEarliest() []string
- func (x *Group) GetFieldKeepLatest() []string
- func (x *Group) GetFieldMath() []*FieldMath
- func (x *Group) GetFieldMerge() []string
- func (x *Group) GetFieldReplace() []string
- func (x *Group) GetFieldReplaceIfMissing() []string
- func (*Group) ProtoMessage()
- func (x *Group) ProtoReflect() protoreflect.Message
- func (x *Group) Reset()
- func (x *Group) String() string
- type IngesterClient
- type IngesterServer
- type MergeConfig
- func (*MergeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *MergeConfig) GetExistingAsMaster() bool
- func (x *MergeConfig) GetGroups() []*Group
- func (x *MergeConfig) GetLinkKey() string
- func (x *MergeConfig) GetMode() string
- func (x *MergeConfig) GetType() string
- func (*MergeConfig) ProtoMessage()
- func (x *MergeConfig) ProtoReflect() protoreflect.Message
- func (x *MergeConfig) Reset()
- func (x *MergeConfig) String() string
- type UnimplementedIngesterServer
- type UnsafeIngesterServer
Constants ¶
This section is empty.
Variables ¶
var File_ingester_api_proto protoreflect.FileDescriptor
var Ingester_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.Ingester", HandlerType: (*IngesterServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Ingest", Handler: _Ingester_Ingest_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ingester-api.proto", }
Ingester_ServiceDesc is the grpc.ServiceDesc for Ingester service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterIngesterServer ¶
func RegisterIngesterServer(s grpc.ServiceRegistrar, srv IngesterServer)
Types ¶
type BulkIngestRequest ¶
type BulkIngestRequest struct { UUID string `protobuf:"bytes,1,opt,name=UUID,json=uuid,proto3" json:"UUID,omitempty"` DocumentType string `protobuf:"bytes,2,opt,name=DocumentType,json=documentType,proto3" json:"DocumentType,omitempty"` MergeConfigs []*MergeConfig `protobuf:"bytes,3,rep,name=MergeConfigs,json=merge,proto3" json:"MergeConfigs,omitempty"` Documents []*Document `protobuf:"bytes,4,rep,name=Documents,json=docs,proto3" json:"Documents,omitempty"` // contains filtered or unexported fields }
func (*BulkIngestRequest) Descriptor
deprecated
func (*BulkIngestRequest) Descriptor() ([]byte, []int)
Deprecated: Use BulkIngestRequest.ProtoReflect.Descriptor instead.
func (*BulkIngestRequest) GetDocumentType ¶
func (x *BulkIngestRequest) GetDocumentType() string
func (*BulkIngestRequest) GetDocuments ¶
func (x *BulkIngestRequest) GetDocuments() []*Document
func (*BulkIngestRequest) GetMergeConfigs ¶
func (x *BulkIngestRequest) GetMergeConfigs() []*MergeConfig
func (*BulkIngestRequest) GetUUID ¶
func (x *BulkIngestRequest) GetUUID() string
func (*BulkIngestRequest) ProtoMessage ¶
func (*BulkIngestRequest) ProtoMessage()
func (*BulkIngestRequest) ProtoReflect ¶
func (x *BulkIngestRequest) ProtoReflect() protoreflect.Message
func (*BulkIngestRequest) Reset ¶
func (x *BulkIngestRequest) Reset()
func (*BulkIngestRequest) String ¶
func (x *BulkIngestRequest) String() string
type BulkIngestResponse ¶
type BulkIngestResponse struct { Status string `protobuf:"bytes,1,opt,name=Status,proto3" json:"Status,omitempty"` // contains filtered or unexported fields }
func (*BulkIngestResponse) Descriptor
deprecated
func (*BulkIngestResponse) Descriptor() ([]byte, []int)
Deprecated: Use BulkIngestResponse.ProtoReflect.Descriptor instead.
func (*BulkIngestResponse) GetStatus ¶
func (x *BulkIngestResponse) GetStatus() string
func (*BulkIngestResponse) ProtoMessage ¶
func (*BulkIngestResponse) ProtoMessage()
func (*BulkIngestResponse) ProtoReflect ¶
func (x *BulkIngestResponse) ProtoReflect() protoreflect.Message
func (*BulkIngestResponse) Reset ¶
func (x *BulkIngestResponse) Reset()
func (*BulkIngestResponse) String ¶
func (x *BulkIngestResponse) String() string
type Document ¶
type Document struct { ID string `protobuf:"bytes,1,opt,name=ID,json=id,proto3" json:"ID,omitempty"` Index string `protobuf:"bytes,2,opt,name=Index,json=index,proto3" json:"Index,omitempty"` IndexType string `protobuf:"bytes,3,opt,name=IndexType,json=type,proto3" json:"IndexType,omitempty"` Source *_struct.Struct `protobuf:"bytes,4,opt,name=Source,json=source,proto3" json:"Source,omitempty"` // contains filtered or unexported fields }
func (*Document) Descriptor
deprecated
func (*Document) GetIndexType ¶
func (*Document) ProtoMessage ¶
func (*Document) ProtoMessage()
func (*Document) ProtoReflect ¶
func (x *Document) ProtoReflect() protoreflect.Message
type FieldMath ¶
type FieldMath struct { Expression string `protobuf:"bytes,1,opt,name=Expression,json=expression,proto3" json:"Expression,omitempty"` OutputField string `protobuf:"bytes,2,opt,name=OutputField,json=outputField,proto3" json:"OutputField,omitempty"` // contains filtered or unexported fields }
func (*FieldMath) Descriptor
deprecated
func (*FieldMath) GetExpression ¶
func (*FieldMath) GetOutputField ¶
func (*FieldMath) ProtoMessage ¶
func (*FieldMath) ProtoMessage()
func (*FieldMath) ProtoReflect ¶
func (x *FieldMath) ProtoReflect() protoreflect.Message
type Group ¶
type Group struct { Condition string `protobuf:"bytes,1,opt,name=Condition,json=condition,proto3" json:"Condition,omitempty"` FieldReplace []string `protobuf:"bytes,2,rep,name=FieldReplace,json=fieldReplace,proto3" json:"FieldReplace,omitempty"` FieldReplaceIfMissing []string `protobuf:"bytes,3,rep,name=FieldReplaceIfMissing,json=fieldReplaceIfMissing,proto3" json:"FieldReplaceIfMissing,omitempty"` FieldMerge []string `protobuf:"bytes,4,rep,name=FieldMerge,json=fieldMerge,proto3" json:"FieldMerge,omitempty"` FieldKeepLatest []string `protobuf:"bytes,6,rep,name=FieldKeepLatest,json=fieldMath,proto3" json:"FieldKeepLatest,omitempty"` FieldKeepEarliest []string `protobuf:"bytes,7,rep,name=FieldKeepEarliest,json=fieldKeepLatest,proto3" json:"FieldKeepEarliest,omitempty"` FieldForceUpdate []string `protobuf:"bytes,8,rep,name=FieldForceUpdate,json=fieldKeepEarliest,proto3" json:"FieldForceUpdate,omitempty"` FieldMath []*FieldMath `protobuf:"bytes,5,rep,name=FieldMath,json=fieldForceUpdate,proto3" json:"FieldMath,omitempty"` // contains filtered or unexported fields }
func (*Group) Descriptor
deprecated
func (*Group) GetCondition ¶
func (*Group) GetFieldForceUpdate ¶
func (*Group) GetFieldKeepEarliest ¶
func (*Group) GetFieldKeepLatest ¶
func (*Group) GetFieldMath ¶
func (*Group) GetFieldMerge ¶
func (*Group) GetFieldReplace ¶
func (*Group) GetFieldReplaceIfMissing ¶
func (*Group) ProtoMessage ¶
func (*Group) ProtoMessage()
func (*Group) ProtoReflect ¶
func (x *Group) ProtoReflect() protoreflect.Message
type IngesterClient ¶
type IngesterClient interface {
Ingest(ctx context.Context, in *BulkIngestRequest, opts ...grpc.CallOption) (*BulkIngestResponse, error)
}
IngesterClient is the client API for Ingester service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewIngesterClient ¶
func NewIngesterClient(cc grpc.ClientConnInterface) IngesterClient
type IngesterServer ¶
type IngesterServer interface { Ingest(context.Context, *BulkIngestRequest) (*BulkIngestResponse, error) // contains filtered or unexported methods }
IngesterServer is the server API for Ingester service. All implementations must embed UnimplementedIngesterServer for forward compatibility
type MergeConfig ¶
type MergeConfig struct { ExistingAsMaster bool `protobuf:"varint,1,opt,name=ExistingAsMaster,json=mode,proto3" json:"ExistingAsMaster,omitempty"` Mode string `protobuf:"bytes,2,opt,name=Mode,json=existingAsMaster,proto3" json:"Mode,omitempty"` Type string `protobuf:"bytes,3,opt,name=Type,json=type,proto3" json:"Type,omitempty"` LinkKey string `protobuf:"bytes,4,opt,name=LinkKey,json=linkKey,proto3" json:"LinkKey,omitempty"` Groups []*Group `protobuf:"bytes,5,rep,name=Groups,json=groups,proto3" json:"Groups,omitempty"` // contains filtered or unexported fields }
func (*MergeConfig) Descriptor
deprecated
func (*MergeConfig) Descriptor() ([]byte, []int)
Deprecated: Use MergeConfig.ProtoReflect.Descriptor instead.
func (*MergeConfig) GetExistingAsMaster ¶
func (x *MergeConfig) GetExistingAsMaster() bool
func (*MergeConfig) GetGroups ¶
func (x *MergeConfig) GetGroups() []*Group
func (*MergeConfig) GetLinkKey ¶
func (x *MergeConfig) GetLinkKey() string
func (*MergeConfig) GetMode ¶
func (x *MergeConfig) GetMode() string
func (*MergeConfig) GetType ¶
func (x *MergeConfig) GetType() string
func (*MergeConfig) ProtoMessage ¶
func (*MergeConfig) ProtoMessage()
func (*MergeConfig) ProtoReflect ¶
func (x *MergeConfig) ProtoReflect() protoreflect.Message
func (*MergeConfig) Reset ¶
func (x *MergeConfig) Reset()
func (*MergeConfig) String ¶
func (x *MergeConfig) String() string
type UnimplementedIngesterServer ¶
type UnimplementedIngesterServer struct { }
UnimplementedIngesterServer must be embedded to have forward compatible implementations.
func (UnimplementedIngesterServer) Ingest ¶
func (UnimplementedIngesterServer) Ingest(context.Context, *BulkIngestRequest) (*BulkIngestResponse, error)
type UnsafeIngesterServer ¶
type UnsafeIngesterServer interface {
// contains filtered or unexported methods
}
UnsafeIngesterServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to IngesterServer will result in compilation errors.