Documentation ¶
Index ¶
- Variables
- func RegisterElasticsearchServer(s grpc.ServiceRegistrar, srv ElasticsearchServer)
- type Bucket
- func (in *Bucket) DeepCopy() *Bucket
- func (in *Bucket) DeepCopyInterface() interface{}
- func (in *Bucket) DeepCopyInto(out *Bucket)
- func (*Bucket) Descriptor() ([]byte, []int)deprecated
- func (x *Bucket) GetX() int64
- func (x *Bucket) GetY() int64
- func (*Bucket) ProtoMessage()
- func (x *Bucket) ProtoReflect() protoreflect.Message
- func (x *Bucket) Reset()
- func (x *Bucket) String() string
- type ElasticsearchClient
- type ElasticsearchServer
- type GetLogsRequest
- func (in *GetLogsRequest) DeepCopy() *GetLogsRequest
- func (in *GetLogsRequest) DeepCopyInterface() interface{}
- func (in *GetLogsRequest) DeepCopyInto(out *GetLogsRequest)
- func (*GetLogsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetLogsRequest) GetName() string
- func (x *GetLogsRequest) GetQuery() *Query
- func (x *GetLogsRequest) GetScrollID() string
- func (x *GetLogsRequest) GetTimeEnd() int64
- func (x *GetLogsRequest) GetTimeStart() int64
- func (*GetLogsRequest) ProtoMessage()
- func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
- func (x *GetLogsRequest) Reset()
- func (x *GetLogsRequest) String() string
- type GetLogsResponse
- func (in *GetLogsResponse) DeepCopy() *GetLogsResponse
- func (in *GetLogsResponse) DeepCopyInterface() interface{}
- func (in *GetLogsResponse) DeepCopyInto(out *GetLogsResponse)
- func (*GetLogsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetLogsResponse) GetBuckets() []*Bucket
- func (x *GetLogsResponse) GetHits() int64
- func (x *GetLogsResponse) GetLogs() string
- func (x *GetLogsResponse) GetScrollID() string
- func (x *GetLogsResponse) GetTook() int64
- func (*GetLogsResponse) ProtoMessage()
- func (x *GetLogsResponse) ProtoReflect() protoreflect.Message
- func (x *GetLogsResponse) Reset()
- func (x *GetLogsResponse) String() string
- type Query
- func (in *Query) DeepCopy() *Query
- func (in *Query) DeepCopyInterface() interface{}
- func (in *Query) DeepCopyInto(out *Query)
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetFields() []string
- func (x *Query) GetName() string
- func (x *Query) GetQuery() string
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- type Spec
- func (in *Spec) DeepCopy() *Spec
- func (in *Spec) DeepCopyInterface() interface{}
- func (in *Spec) DeepCopyInto(out *Spec)
- func (*Spec) Descriptor() ([]byte, []int)deprecated
- func (x *Spec) GetQueries() []*Query
- func (*Spec) ProtoMessage()
- func (x *Spec) ProtoReflect() protoreflect.Message
- func (x *Spec) Reset()
- func (x *Spec) String() string
- type UnimplementedElasticsearchServer
- type UnsafeElasticsearchServer
Constants ¶
This section is empty.
Variables ¶
var Elasticsearch_ServiceDesc = grpc.ServiceDesc{ ServiceName: "plugins.elasticsearch.Elasticsearch", HandlerType: (*ElasticsearchServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetLogs", Handler: _Elasticsearch_GetLogs_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "elasticsearch.proto", }
Elasticsearch_ServiceDesc is the grpc.ServiceDesc for Elasticsearch service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_elasticsearch_proto protoreflect.FileDescriptor
Functions ¶
func RegisterElasticsearchServer ¶
func RegisterElasticsearchServer(s grpc.ServiceRegistrar, srv ElasticsearchServer)
Types ¶
type Bucket ¶
type Bucket struct { X int64 `protobuf:"varint,1,opt,name=x,proto3" json:"x,omitempty"` Y int64 `protobuf:"varint,2,opt,name=y,proto3" json:"y,omitempty"` // contains filtered or unexported fields }
Bucket is one bucket for the logs bar chart. Each bucket must contain a timestamp (x value) and the number of log lines for this timestamp (y value).
func (*Bucket) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Bucket. Required by controller-gen.
func (*Bucket) DeepCopyInterface ¶
func (in *Bucket) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Bucket. Required by controller-gen.
func (*Bucket) DeepCopyInto ¶
DeepCopyInto supports using Bucket within kubernetes types, where deepcopy-gen is used.
func (*Bucket) Descriptor
deprecated
func (*Bucket) ProtoMessage ¶
func (*Bucket) ProtoMessage()
func (*Bucket) ProtoReflect ¶
func (x *Bucket) ProtoReflect() protoreflect.Message
type ElasticsearchClient ¶
type ElasticsearchClient interface {
GetLogs(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsResponse, error)
}
ElasticsearchClient is the client API for Elasticsearch 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 NewElasticsearchClient ¶
func NewElasticsearchClient(cc grpc.ClientConnInterface) ElasticsearchClient
type ElasticsearchServer ¶
type ElasticsearchServer interface { GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error) // contains filtered or unexported methods }
ElasticsearchServer is the server API for Elasticsearch service. All implementations must embed UnimplementedElasticsearchServer for forward compatibility
type GetLogsRequest ¶
type GetLogsRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ScrollID string `protobuf:"bytes,2,opt,name=scrollID,proto3" json:"scrollID,omitempty"` TimeStart int64 `protobuf:"varint,3,opt,name=timeStart,proto3" json:"timeStart,omitempty"` TimeEnd int64 `protobuf:"varint,4,opt,name=timeEnd,proto3" json:"timeEnd,omitempty"` Query *Query `protobuf:"bytes,5,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
GetLogsRequest is the structure of a call to get the logs for a query. It must contain the name of the datasource, an optional scroll id, which can be used for pagination, the time range and a query.
func (*GetLogsRequest) DeepCopy ¶
func (in *GetLogsRequest) DeepCopy() *GetLogsRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetLogsRequest. Required by controller-gen.
func (*GetLogsRequest) DeepCopyInterface ¶
func (in *GetLogsRequest) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GetLogsRequest. Required by controller-gen.
func (*GetLogsRequest) DeepCopyInto ¶
func (in *GetLogsRequest) DeepCopyInto(out *GetLogsRequest)
DeepCopyInto supports using GetLogsRequest within kubernetes types, where deepcopy-gen is used.
func (*GetLogsRequest) Descriptor
deprecated
func (*GetLogsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetLogsRequest.ProtoReflect.Descriptor instead.
func (*GetLogsRequest) GetName ¶
func (x *GetLogsRequest) GetName() string
func (*GetLogsRequest) GetQuery ¶
func (x *GetLogsRequest) GetQuery() *Query
func (*GetLogsRequest) GetScrollID ¶
func (x *GetLogsRequest) GetScrollID() string
func (*GetLogsRequest) GetTimeEnd ¶
func (x *GetLogsRequest) GetTimeEnd() int64
func (*GetLogsRequest) GetTimeStart ¶
func (x *GetLogsRequest) GetTimeStart() int64
func (*GetLogsRequest) ProtoMessage ¶
func (*GetLogsRequest) ProtoMessage()
func (*GetLogsRequest) ProtoReflect ¶
func (x *GetLogsRequest) ProtoReflect() protoreflect.Message
func (*GetLogsRequest) Reset ¶
func (x *GetLogsRequest) Reset()
func (*GetLogsRequest) String ¶
func (x *GetLogsRequest) String() string
type GetLogsResponse ¶
type GetLogsResponse struct { ScrollID string `protobuf:"bytes,1,opt,name=scrollID,proto3" json:"scrollID,omitempty"` Hits int64 `protobuf:"varint,2,opt,name=hits,proto3" json:"hits,omitempty"` Took int64 `protobuf:"varint,3,opt,name=took,proto3" json:"took,omitempty"` Logs string `protobuf:"bytes,4,opt,name=logs,proto3" json:"logs,omitempty"` Buckets []*Bucket `protobuf:"bytes,5,rep,name=buckets,proto3" json:"buckets,omitempty"` // contains filtered or unexported fields }
GetLogsResponse is the response for a GetLogs call. It contains the hits (number of documentes), the time, which was needed to execute the query and a scroll id for pagination. It also contains all logs as single string, which must be parsed in the frontend and a list of buckets, to visulize the distribution of the logs in the selected time range.
func (*GetLogsResponse) DeepCopy ¶
func (in *GetLogsResponse) DeepCopy() *GetLogsResponse
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetLogsResponse. Required by controller-gen.
func (*GetLogsResponse) DeepCopyInterface ¶
func (in *GetLogsResponse) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GetLogsResponse. Required by controller-gen.
func (*GetLogsResponse) DeepCopyInto ¶
func (in *GetLogsResponse) DeepCopyInto(out *GetLogsResponse)
DeepCopyInto supports using GetLogsResponse within kubernetes types, where deepcopy-gen is used.
func (*GetLogsResponse) Descriptor
deprecated
func (*GetLogsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetLogsResponse.ProtoReflect.Descriptor instead.
func (*GetLogsResponse) GetBuckets ¶
func (x *GetLogsResponse) GetBuckets() []*Bucket
func (*GetLogsResponse) GetHits ¶
func (x *GetLogsResponse) GetHits() int64
func (*GetLogsResponse) GetLogs ¶
func (x *GetLogsResponse) GetLogs() string
func (*GetLogsResponse) GetScrollID ¶
func (x *GetLogsResponse) GetScrollID() string
func (*GetLogsResponse) GetTook ¶
func (x *GetLogsResponse) GetTook() int64
func (*GetLogsResponse) ProtoMessage ¶
func (*GetLogsResponse) ProtoMessage()
func (*GetLogsResponse) ProtoReflect ¶
func (x *GetLogsResponse) ProtoReflect() protoreflect.Message
func (*GetLogsResponse) Reset ¶
func (x *GetLogsResponse) Reset()
func (*GetLogsResponse) String ¶
func (x *GetLogsResponse) String() string
type Query ¶
type Query struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` Fields []string `protobuf:"bytes,3,rep,name=fields,proto3" json:"fields,omitempty"` // contains filtered or unexported fields }
Query represents a single query for an application. A query is identified by a name, a query and a list of fields, which should be shown in the results table. If the fields list is empty, we show the complete document in the table.
func (*Query) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Query. Required by controller-gen.
func (*Query) DeepCopyInterface ¶
func (in *Query) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Query. Required by controller-gen.
func (*Query) DeepCopyInto ¶
DeepCopyInto supports using Query within kubernetes types, where deepcopy-gen is used.
func (*Query) Descriptor
deprecated
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type Spec ¶
type Spec struct { Queries []*Query `protobuf:"bytes,2,rep,name=queries,proto3" json:"queries,omitempty"` // contains filtered or unexported fields }
Spec implements the specification for an application. This field is then used in the Application CR and contains, all possible fields, which can be used by a user to work with their logs in Elasticsaerch.
func (*Spec) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Spec. Required by controller-gen.
func (*Spec) DeepCopyInterface ¶
func (in *Spec) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Spec. Required by controller-gen.
func (*Spec) DeepCopyInto ¶
DeepCopyInto supports using Spec within kubernetes types, where deepcopy-gen is used.
func (*Spec) Descriptor
deprecated
func (*Spec) GetQueries ¶
func (*Spec) ProtoMessage ¶
func (*Spec) ProtoMessage()
func (*Spec) ProtoReflect ¶
func (x *Spec) ProtoReflect() protoreflect.Message
type UnimplementedElasticsearchServer ¶
type UnimplementedElasticsearchServer struct { }
UnimplementedElasticsearchServer must be embedded to have forward compatible implementations.
func (UnimplementedElasticsearchServer) GetLogs ¶
func (UnimplementedElasticsearchServer) GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error)
type UnsafeElasticsearchServer ¶
type UnsafeElasticsearchServer interface {
// contains filtered or unexported methods
}
UnsafeElasticsearchServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ElasticsearchServer will result in compilation errors.