seer

package
v0.0.0-...-768eb72 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2018 License: AGPL-3.0 Imports: 7 Imported by: 2

Documentation

Overview

Package seer is a generated protocol buffer package.

It is generated from these files: 

seer.proto

It has these top-level messages: 

Stream
Event
Interval
Forecast
CreateStreamRequest
GetStreamRequest
DeleteStreamRequest
ListStreamsRequest
ListStreamsResponse
UpdateStreamRequest
GetForecastRequest

Index

Constants

This section is empty.

Variables

View Source 
var Domain_name = map[int32]string{
	0: "CONTINUOUS",
	1: "CONTINUOUS_RIGHT",
	2: "CONTINUOUS_INTERVAL",
	3: "DISCRETE_RIGHT",
	4: "DISCRETE_INTERVAL",
}
View Source 
var Domain_value = map[string]int32{
	"CONTINUOUS":          0,
	"CONTINUOUS_RIGHT":    1,
	"CONTINUOUS_INTERVAL": 2,
	"DISCRETE_RIGHT":      3,
	"DISCRETE_INTERVAL":   4,
}

Functions

func RegisterSeerServer 

func RegisterSeerServer(s *grpc.Server, srv SeerServer)

Types

type CreateStreamRequest 

type CreateStreamRequest struct {
	Stream *Stream `protobuf:"bytes,1,opt,name=stream" json:"stream,omitempty"`
}

The request message containing the stream to be created

func (*CreateStreamRequest) Descriptor 

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

func (*CreateStreamRequest) GetStream 

func (m *CreateStreamRequest) GetStream() *Stream

func (*CreateStreamRequest) ProtoMessage 

func (*CreateStreamRequest) ProtoMessage()

func (*CreateStreamRequest) Reset 

func (m *CreateStreamRequest) Reset()

func (*CreateStreamRequest) String 

func (m *CreateStreamRequest) String() string

type DeleteStreamRequest 

type DeleteStreamRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

The request message containing the name of the stream to be deleted

func (*DeleteStreamRequest) Descriptor 

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

func (*DeleteStreamRequest) GetName 

func (m *DeleteStreamRequest) GetName() string

func (*DeleteStreamRequest) ProtoMessage 

func (*DeleteStreamRequest) ProtoMessage()

func (*DeleteStreamRequest) Reset 

func (m *DeleteStreamRequest) Reset()

func (*DeleteStreamRequest) String 

func (m *DeleteStreamRequest) String() string

type Domain 

type Domain int32
const (
	Domain_CONTINUOUS          Domain = 0
	Domain_CONTINUOUS_RIGHT    Domain = 1
	Domain_CONTINUOUS_INTERVAL Domain = 2
	Domain_DISCRETE_RIGHT      Domain = 3
	Domain_DISCRETE_INTERVAL   Domain = 4
)

func (Domain) EnumDescriptor 

func (Domain) EnumDescriptor() ([]byte, []int)

func (Domain) String 

func (x Domain) String() string

type Event 

type Event struct {
	Times  []*google_protobuf1.Timestamp `protobuf:"bytes,1,rep,name=times" json:"times,omitempty"`
	Values []float64                     `protobuf:"fixed64,2,rep,packed,name=values" json:"values,omitempty"`
}

A set of ordered events (values and times) in a stream

func (*Event) Descriptor 

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

func (*Event) GetTimes 

func (m *Event) GetTimes() []*google_protobuf1.Timestamp

func (*Event) GetValues 

func (m *Event) GetValues() []float64

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) String 

func (m *Event) String() string

type Forecast 

type Forecast struct {
	Times     []*google_protobuf1.Timestamp `protobuf:"bytes,1,rep,name=times" json:"times,omitempty"`
	Values    []float64                     `protobuf:"fixed64,2,rep,packed,name=values" json:"values,omitempty"`
	Intervals []*Interval                   `protobuf:"bytes,3,rep,name=intervals" json:"intervals,omitempty"`
}

A forecast, with point predictions and confidence intervals

func (*Forecast) Descriptor 

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

func (*Forecast) GetIntervals 

func (m *Forecast) GetIntervals() []*Interval

func (*Forecast) GetTimes 

func (m *Forecast) GetTimes() []*google_protobuf1.Timestamp

func (*Forecast) GetValues 

func (m *Forecast) GetValues() []float64

func (*Forecast) ProtoMessage 

func (*Forecast) ProtoMessage()

func (*Forecast) Reset 

func (m *Forecast) Reset()

func (*Forecast) String 

func (m *Forecast) String() string

type GetForecastRequest 

type GetForecastRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	N    int32  `protobuf:"varint,2,opt,name=n" json:"n,omitempty"`
}

The request message containing the forecast length

func (*GetForecastRequest) Descriptor 

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

func (*GetForecastRequest) GetN 

func (m *GetForecastRequest) GetN() int32

func (*GetForecastRequest) GetName 

func (m *GetForecastRequest) GetName() string

func (*GetForecastRequest) ProtoMessage 

func (*GetForecastRequest) ProtoMessage()

func (*GetForecastRequest) Reset 

func (m *GetForecastRequest) Reset()

func (*GetForecastRequest) String 

func (m *GetForecastRequest) String() string

type GetStreamRequest 

type GetStreamRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
}

The request message containing the name of the requested stream

func (*GetStreamRequest) Descriptor 

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

func (*GetStreamRequest) GetName 

func (m *GetStreamRequest) GetName() string

func (*GetStreamRequest) ProtoMessage 

func (*GetStreamRequest) ProtoMessage()

func (*GetStreamRequest) Reset 

func (m *GetStreamRequest) Reset()

func (*GetStreamRequest) String 

func (m *GetStreamRequest) String() string

type Interval 

type Interval struct {
	Probability float64   `protobuf:"fixed64,1,opt,name=probability" json:"probability,omitempty"`
	LowerBound  []float64 `protobuf:"fixed64,2,rep,packed,name=lower_bound,json=lowerBound" json:"lower_bound,omitempty"`
	UpperBound  []float64 `protobuf:"fixed64,3,rep,packed,name=upper_bound,json=upperBound" json:"upper_bound,omitempty"`
}

A confidence interval

func (*Interval) Descriptor 

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

func (*Interval) GetLowerBound 

func (m *Interval) GetLowerBound() []float64

func (*Interval) GetProbability 

func (m *Interval) GetProbability() float64

func (*Interval) GetUpperBound 

func (m *Interval) GetUpperBound() []float64

func (*Interval) ProtoMessage 

func (*Interval) ProtoMessage()

func (*Interval) Reset 

func (m *Interval) Reset()

func (*Interval) String 

func (m *Interval) String() string

type ListStreamsRequest 

type ListStreamsRequest struct {
	PageSize   int32 `protobuf:"varint,1,opt,name=page_size,json=pageSize" json:"page_size,omitempty"`
	PageNumber int32 `protobuf:"varint,2,opt,name=page_number,json=pageNumber" json:"page_number,omitempty"`
}

The request message containing the paging data for the stream to list

func (*ListStreamsRequest) Descriptor 

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

func (*ListStreamsRequest) GetPageNumber 

func (m *ListStreamsRequest) GetPageNumber() int32

func (*ListStreamsRequest) GetPageSize 

func (m *ListStreamsRequest) GetPageSize() int32

func (*ListStreamsRequest) ProtoMessage 

func (*ListStreamsRequest) ProtoMessage()

func (*ListStreamsRequest) Reset 

func (m *ListStreamsRequest) Reset()

func (*ListStreamsRequest) String 

func (m *ListStreamsRequest) String() string

type ListStreamsResponse 

type ListStreamsResponse struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams" json:"streams,omitempty"`
}

The response message containing a list of streams

func (*ListStreamsResponse) Descriptor 

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

func (*ListStreamsResponse) GetStreams 

func (m *ListStreamsResponse) GetStreams() []*Stream

func (*ListStreamsResponse) ProtoMessage 

func (*ListStreamsResponse) ProtoMessage()

func (*ListStreamsResponse) Reset 

func (m *ListStreamsResponse) Reset()

func (*ListStreamsResponse) String 

func (m *ListStreamsResponse) String() string

type SeerClient 

type SeerClient interface {
	CreateStream(ctx context.Context, in *CreateStreamRequest, opts ...grpc.CallOption) (*Stream, error)
	GetStream(ctx context.Context, in *GetStreamRequest, opts ...grpc.CallOption) (*Stream, error)
	UpdateStream(ctx context.Context, in *UpdateStreamRequest, opts ...grpc.CallOption) (*Stream, error)
	DeleteStream(ctx context.Context, in *DeleteStreamRequest, opts ...grpc.CallOption) (*google_protobuf.Empty, error)
	ListStreams(ctx context.Context, in *ListStreamsRequest, opts ...grpc.CallOption) (*ListStreamsResponse, error)
	GetForecast(ctx context.Context, in *GetForecastRequest, opts ...grpc.CallOption) (*Forecast, error)
}

func NewSeerClient 

func NewSeerClient(cc *grpc.ClientConn) SeerClient

type SeerServer 

type SeerServer interface {
	CreateStream(context.Context, *CreateStreamRequest) (*Stream, error)
	GetStream(context.Context, *GetStreamRequest) (*Stream, error)
	UpdateStream(context.Context, *UpdateStreamRequest) (*Stream, error)
	DeleteStream(context.Context, *DeleteStreamRequest) (*google_protobuf.Empty, error)
	ListStreams(context.Context, *ListStreamsRequest) (*ListStreamsResponse, error)
	GetForecast(context.Context, *GetForecastRequest) (*Forecast, error)
}

type Stream 

type Stream struct {
	Name          string                      `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Period        float64                     `protobuf:"fixed64,2,opt,name=period" json:"period,omitempty"`
	LastEventTime *google_protobuf1.Timestamp `protobuf:"bytes,3,opt,name=last_event_time,json=lastEventTime" json:"last_event_time,omitempty"`
	Domain        Domain                      `protobuf:"varint,4,opt,name=domain,enum=seer.Domain" json:"domain,omitempty"`
	Min           float64                     `protobuf:"fixed64,5,opt,name=min" json:"min,omitempty"`
	Max           float64                     `protobuf:"fixed64,6,opt,name=max" json:"max,omitempty"`
}

A data stream

func (*Stream) Descriptor 

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

func (*Stream) GetDomain 

func (m *Stream) GetDomain() Domain

func (*Stream) GetLastEventTime 

func (m *Stream) GetLastEventTime() *google_protobuf1.Timestamp

func (*Stream) GetMax 

func (m *Stream) GetMax() float64

func (*Stream) GetMin 

func (m *Stream) GetMin() float64

func (*Stream) GetName 

func (m *Stream) GetName() string

func (*Stream) GetPeriod 

func (m *Stream) GetPeriod() float64

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) String 

func (m *Stream) String() string

type UpdateStreamRequest 

type UpdateStreamRequest struct {
	Name  string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Event *Event `protobuf:"bytes,2,opt,name=event" json:"event,omitempty"`
}

The request message containing events to apply to the stream

func (*UpdateStreamRequest) Descriptor 

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

func (*UpdateStreamRequest) GetEvent 

func (m *UpdateStreamRequest) GetEvent() *Event

func (*UpdateStreamRequest) GetName 

func (m *UpdateStreamRequest) GetName() string

func (*UpdateStreamRequest) ProtoMessage 

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) Reset 

func (m *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String 

func (m *UpdateStreamRequest) String() string

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.