Versions in this module Expand all Collapse all v0 v0.3.0 Jun 3, 2021 v0.2.0 Apr 23, 2021 v0.1.0 Apr 4, 2021 Changes in this version + var Elasticsearch_ServiceDesc = grpc.ServiceDesc + var File_elasticsearch_proto protoreflect.FileDescriptor + func RegisterElasticsearchServer(s grpc.ServiceRegistrar, srv ElasticsearchServer) + type Bucket struct + X int64 + Y int64 + func (*Bucket) Descriptor() ([]byte, []int) + func (*Bucket) ProtoMessage() + func (in *Bucket) DeepCopy() *Bucket + func (in *Bucket) DeepCopyInterface() interface{} + func (in *Bucket) DeepCopyInto(out *Bucket) + func (x *Bucket) GetX() int64 + func (x *Bucket) GetY() int64 + func (x *Bucket) ProtoReflect() protoreflect.Message + func (x *Bucket) Reset() + func (x *Bucket) String() string + type ElasticsearchClient interface + GetLogs func(ctx context.Context, in *GetLogsRequest, opts ...grpc.CallOption) (*GetLogsResponse, error) + func NewElasticsearchClient(cc grpc.ClientConnInterface) ElasticsearchClient + type ElasticsearchServer interface + GetLogs func(context.Context, *GetLogsRequest) (*GetLogsResponse, error) + type GetLogsRequest struct + Name string + Query *Query + ScrollID string + TimeEnd int64 + TimeStart int64 + func (*GetLogsRequest) Descriptor() ([]byte, []int) + func (*GetLogsRequest) ProtoMessage() + func (in *GetLogsRequest) DeepCopy() *GetLogsRequest + func (in *GetLogsRequest) DeepCopyInterface() interface{} + func (in *GetLogsRequest) DeepCopyInto(out *GetLogsRequest) + 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 (x *GetLogsRequest) ProtoReflect() protoreflect.Message + func (x *GetLogsRequest) Reset() + func (x *GetLogsRequest) String() string + type GetLogsResponse struct + Buckets []*Bucket + Hits int64 + Logs string + ScrollID string + Took int64 + func (*GetLogsResponse) Descriptor() ([]byte, []int) + func (*GetLogsResponse) ProtoMessage() + func (in *GetLogsResponse) DeepCopy() *GetLogsResponse + func (in *GetLogsResponse) DeepCopyInterface() interface{} + func (in *GetLogsResponse) DeepCopyInto(out *GetLogsResponse) + 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 (x *GetLogsResponse) ProtoReflect() protoreflect.Message + func (x *GetLogsResponse) Reset() + func (x *GetLogsResponse) String() string + type Query struct + Fields []string + Name string + Query string + func (*Query) Descriptor() ([]byte, []int) + func (*Query) ProtoMessage() + func (in *Query) DeepCopy() *Query + func (in *Query) DeepCopyInterface() interface{} + func (in *Query) DeepCopyInto(out *Query) + func (x *Query) GetFields() []string + func (x *Query) GetName() string + func (x *Query) GetQuery() string + func (x *Query) ProtoReflect() protoreflect.Message + func (x *Query) Reset() + func (x *Query) String() string + type Spec struct + Queries []*Query + func (*Spec) Descriptor() ([]byte, []int) + func (*Spec) ProtoMessage() + func (in *Spec) DeepCopy() *Spec + func (in *Spec) DeepCopyInterface() interface{} + func (in *Spec) DeepCopyInto(out *Spec) + func (x *Spec) GetQueries() []*Query + func (x *Spec) ProtoReflect() protoreflect.Message + func (x *Spec) Reset() + func (x *Spec) String() string + type UnimplementedElasticsearchServer struct + func (UnimplementedElasticsearchServer) GetLogs(context.Context, *GetLogsRequest) (*GetLogsResponse, error) + type UnsafeElasticsearchServer interface