proto

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 23, 2021 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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)

View Source 
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 

func (in *Bucket) DeepCopy() *Bucket

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 

func (in *Bucket) DeepCopyInto(out *Bucket)

DeepCopyInto supports using Bucket within kubernetes types, where deepcopy-gen is used.

func (*Bucket) Descriptor deprecated 

func (*Bucket) Descriptor() ([]byte, []int)

Deprecated: Use Bucket.ProtoReflect.Descriptor instead.

func (*Bucket) GetX 

func (x *Bucket) GetX() int64

func (*Bucket) GetY 

func (x *Bucket) GetY() int64

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) ProtoReflect 

func (x *Bucket) ProtoReflect() protoreflect.Message

func (*Bucket) Reset 

func (x *Bucket) Reset()

func (*Bucket) String 

func (x *Bucket) String() string

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 

func (in *Query) DeepCopy() *Query

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 

func (in *Query) DeepCopyInto(out *Query)

DeepCopyInto supports using Query within kubernetes types, where deepcopy-gen is used.

func (*Query) Descriptor deprecated 

func (*Query) Descriptor() ([]byte, []int)

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetFields 

func (x *Query) GetFields() []string

func (*Query) GetName 

func (x *Query) GetName() string

func (*Query) GetQuery 

func (x *Query) GetQuery() string

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

func (x *Query) ProtoReflect() protoreflect.Message

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

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 

func (in *Spec) DeepCopy() *Spec

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 

func (in *Spec) DeepCopyInto(out *Spec)

DeepCopyInto supports using Spec within kubernetes types, where deepcopy-gen is used.

func (*Spec) Descriptor deprecated 

func (*Spec) Descriptor() ([]byte, []int)

Deprecated: Use Spec.ProtoReflect.Descriptor instead.

func (*Spec) GetQueries 

func (x *Spec) GetQueries() []*Query

func (*Spec) ProtoMessage 

func (*Spec) ProtoMessage()

func (*Spec) ProtoReflect 

func (x *Spec) ProtoReflect() protoreflect.Message

func (*Spec) Reset 

func (x *Spec) Reset()

func (*Spec) String 

func (x *Spec) String() string

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.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.