mortarpb

package
v1.1.0-beta3 Latest Latest
Warning

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

 Go to latest Published: Dec 16, 2019 License: BSD-3-Clause Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AggFunc_name = map[int32]string{
	0: "AGG_FUNC_INVALID",
	1: "AGG_FUNC_RAW",
	2: "AGG_FUNC_MEAN",
	3: "AGG_FUNC_MIN",
	4: "AGG_FUNC_MAX",
	5: "AGG_FUNC_COUNT",
	6: "AGG_FUNC_SUM",
}
View Source 
var AggFunc_value = map[string]int32{
	"AGG_FUNC_INVALID": 0,
	"AGG_FUNC_RAW":     1,
	"AGG_FUNC_MEAN":    2,
	"AGG_FUNC_MIN":     3,
	"AGG_FUNC_MAX":     4,
	"AGG_FUNC_COUNT":   5,
	"AGG_FUNC_SUM":     6,
}

Functions

func RegisterMortarServer 

func RegisterMortarServer(s *grpc.Server, srv MortarServer)

Types

type APIKeyResponse 

type APIKeyResponse struct {
	Token                string   `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Refreshtoken         string   `protobuf:"bytes,2,opt,name=refreshtoken,proto3" json:"refreshtoken,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*APIKeyResponse) Descriptor 

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

func (*APIKeyResponse) GetRefreshtoken 

func (m *APIKeyResponse) GetRefreshtoken() string

func (*APIKeyResponse) GetToken 

func (m *APIKeyResponse) GetToken() string

func (*APIKeyResponse) ProtoMessage 

func (*APIKeyResponse) ProtoMessage()

func (*APIKeyResponse) Reset 

func (m *APIKeyResponse) Reset()

func (*APIKeyResponse) String 

func (m *APIKeyResponse) String() string

func (*APIKeyResponse) XXX_DiscardUnknown 

func (m *APIKeyResponse) XXX_DiscardUnknown()

func (*APIKeyResponse) XXX_Marshal 

func (m *APIKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*APIKeyResponse) XXX_Merge 

func (m *APIKeyResponse) XXX_Merge(src proto.Message)

func (*APIKeyResponse) XXX_Size 

func (m *APIKeyResponse) XXX_Size() int

func (*APIKeyResponse) XXX_Unmarshal 

func (m *APIKeyResponse) XXX_Unmarshal(b []byte) error

type AggFunc 

type AggFunc int32
const (
	AggFunc_AGG_FUNC_INVALID AggFunc = 0
	AggFunc_AGG_FUNC_RAW     AggFunc = 1
	AggFunc_AGG_FUNC_MEAN    AggFunc = 2
	AggFunc_AGG_FUNC_MIN     AggFunc = 3
	AggFunc_AGG_FUNC_MAX     AggFunc = 4
	AggFunc_AGG_FUNC_COUNT   AggFunc = 5
	AggFunc_AGG_FUNC_SUM     AggFunc = 6
)

func (AggFunc) EnumDescriptor 

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

func (AggFunc) String 

func (x AggFunc) String() string

type DataFrame 

type DataFrame struct {
	// name of the streams
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// aggregation function
	Aggregation AggFunc `protobuf:"varint,2,opt,name=aggregation,proto3,enum=mortar.AggFunc" json:"aggregation,omitempty"`
	// window argument for aggregation
	Window string `protobuf:"bytes,3,opt,name=window,proto3" json:"window,omitempty"`
	// engineering units
	Unit string `protobuf:"bytes,4,opt,name=unit,proto3" json:"unit,omitempty"`
	// refer to variables in Views
	Timeseries []*Timeseries `protobuf:"bytes,5,rep,name=timeseries,proto3" json:"timeseries,omitempty"`
	// instead of vars in views, list the UUIDs explicitly.
	Uuids                []string `protobuf:"bytes,6,rep,name=uuids,proto3" json:"uuids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataFrame) Descriptor 

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

func (*DataFrame) GetAggregation 

func (m *DataFrame) GetAggregation() AggFunc

func (*DataFrame) GetName 

func (m *DataFrame) GetName() string

func (*DataFrame) GetTimeseries 

func (m *DataFrame) GetTimeseries() []*Timeseries

func (*DataFrame) GetUnit 

func (m *DataFrame) GetUnit() string

func (*DataFrame) GetUuids 

func (m *DataFrame) GetUuids() []string

func (*DataFrame) GetWindow 

func (m *DataFrame) GetWindow() string

func (*DataFrame) ProtoMessage 

func (*DataFrame) ProtoMessage()

func (*DataFrame) Reset 

func (m *DataFrame) Reset()

func (*DataFrame) String 

func (m *DataFrame) String() string

func (*DataFrame) XXX_DiscardUnknown 

func (m *DataFrame) XXX_DiscardUnknown()

func (*DataFrame) XXX_Marshal 

func (m *DataFrame) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataFrame) XXX_Merge 

func (m *DataFrame) XXX_Merge(src proto.Message)

func (*DataFrame) XXX_Size 

func (m *DataFrame) XXX_Size() int

func (*DataFrame) XXX_Unmarshal 

func (m *DataFrame) XXX_Unmarshal(b []byte) error

type FetchRequest 

type FetchRequest struct {
	// the list of sites to execute against
	Sites []string `protobuf:"bytes,1,rep,name=sites,proto3" json:"sites,omitempty"`
	// list of streams to download
	Streams []*Stream `protobuf:"bytes,2,rep,name=streams,proto3" json:"streams,omitempty"`
	// temporal parameters for all streams
	// (range of data to download, resolution)
	Time                 *TimeParams  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	Views                []*View      `protobuf:"bytes,4,rep,name=views,proto3" json:"views,omitempty"`
	DataFrames           []*DataFrame `protobuf:"bytes,5,rep,name=dataFrames,proto3" json:"dataFrames,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*FetchRequest) Descriptor 

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

func (*FetchRequest) GetDataFrames 

func (m *FetchRequest) GetDataFrames() []*DataFrame

func (*FetchRequest) GetSites 

func (m *FetchRequest) GetSites() []string

func (*FetchRequest) GetStreams 

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

func (*FetchRequest) GetTime 

func (m *FetchRequest) GetTime() *TimeParams

func (*FetchRequest) GetViews 

func (m *FetchRequest) GetViews() []*View

func (*FetchRequest) ProtoMessage 

func (*FetchRequest) ProtoMessage()

func (*FetchRequest) Reset 

func (m *FetchRequest) Reset()

func (*FetchRequest) String 

func (m *FetchRequest) String() string

func (*FetchRequest) XXX_DiscardUnknown 

func (m *FetchRequest) XXX_DiscardUnknown()

func (*FetchRequest) XXX_Marshal 

func (m *FetchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchRequest) XXX_Merge 

func (m *FetchRequest) XXX_Merge(src proto.Message)

func (*FetchRequest) XXX_Size 

func (m *FetchRequest) XXX_Size() int

func (*FetchRequest) XXX_Unmarshal 

func (m *FetchRequest) XXX_Unmarshal(b []byte) error

type FetchResponse 

type FetchResponse struct {
	// error from backend
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// stream definition fields:
	// - site name
	// - view name
	// - data frame name
	// - variable name (from View definition)
	Site      string `protobuf:"bytes,2,opt,name=site,proto3" json:"site,omitempty"`
	View      string `protobuf:"bytes,9,opt,name=view,proto3" json:"view,omitempty"`
	DataFrame string `protobuf:"bytes,10,opt,name=dataFrame,proto3" json:"dataFrame,omitempty"`
	Variable  string `protobuf:"bytes,3,opt,name=variable,proto3" json:"variable,omitempty"`
	// uuid
	Identifier string `protobuf:"bytes,4,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// timestamps and value should have same length
	Times  []int64   `protobuf:"varint,5,rep,packed,name=times,proto3" json:"times,omitempty"`
	Values []float64 `protobuf:"fixed64,6,rep,packed,name=values,proto3" json:"values,omitempty"`
	// brick query contents related to this variable
	Variables            []string `protobuf:"bytes,7,rep,name=variables,proto3" json:"variables,omitempty"`
	Rows                 []*Row   `protobuf:"bytes,8,rep,name=rows,proto3" json:"rows,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchResponse) Descriptor 

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

func (*FetchResponse) GetDataFrame 

func (m *FetchResponse) GetDataFrame() string

func (*FetchResponse) GetError 

func (m *FetchResponse) GetError() string

func (*FetchResponse) GetIdentifier 

func (m *FetchResponse) GetIdentifier() string

func (*FetchResponse) GetRows 

func (m *FetchResponse) GetRows() []*Row

func (*FetchResponse) GetSite 

func (m *FetchResponse) GetSite() string

func (*FetchResponse) GetTimes 

func (m *FetchResponse) GetTimes() []int64

func (*FetchResponse) GetValues 

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

func (*FetchResponse) GetVariable 

func (m *FetchResponse) GetVariable() string

func (*FetchResponse) GetVariables 

func (m *FetchResponse) GetVariables() []string

func (*FetchResponse) GetView 

func (m *FetchResponse) GetView() string

func (*FetchResponse) ProtoMessage 

func (*FetchResponse) ProtoMessage()

func (*FetchResponse) Reset 

func (m *FetchResponse) Reset()

func (*FetchResponse) String 

func (m *FetchResponse) String() string

func (*FetchResponse) XXX_DiscardUnknown 

func (m *FetchResponse) XXX_DiscardUnknown()

func (*FetchResponse) XXX_Marshal 

func (m *FetchResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchResponse) XXX_Merge 

func (m *FetchResponse) XXX_Merge(src proto.Message)

func (*FetchResponse) XXX_Size 

func (m *FetchResponse) XXX_Size() int

func (*FetchResponse) XXX_Unmarshal 

func (m *FetchResponse) XXX_Unmarshal(b []byte) error

type GetAPIKeyRequest 

type GetAPIKeyRequest struct {
	Username             string   `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password             string   `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	Refreshtoken         string   `protobuf:"bytes,3,opt,name=refreshtoken,proto3" json:"refreshtoken,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetAPIKeyRequest) Descriptor 

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

func (*GetAPIKeyRequest) GetPassword 

func (m *GetAPIKeyRequest) GetPassword() string

func (*GetAPIKeyRequest) GetRefreshtoken 

func (m *GetAPIKeyRequest) GetRefreshtoken() string

func (*GetAPIKeyRequest) GetUsername 

func (m *GetAPIKeyRequest) GetUsername() string

func (*GetAPIKeyRequest) ProtoMessage 

func (*GetAPIKeyRequest) ProtoMessage()

func (*GetAPIKeyRequest) Reset 

func (m *GetAPIKeyRequest) Reset()

func (*GetAPIKeyRequest) String 

func (m *GetAPIKeyRequest) String() string

func (*GetAPIKeyRequest) XXX_DiscardUnknown 

func (m *GetAPIKeyRequest) XXX_DiscardUnknown()

func (*GetAPIKeyRequest) XXX_Marshal 

func (m *GetAPIKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetAPIKeyRequest) XXX_Merge 

func (m *GetAPIKeyRequest) XXX_Merge(src proto.Message)

func (*GetAPIKeyRequest) XXX_Size 

func (m *GetAPIKeyRequest) XXX_Size() int

func (*GetAPIKeyRequest) XXX_Unmarshal 

func (m *GetAPIKeyRequest) XXX_Unmarshal(b []byte) error

type MortarClient 

type MortarClient interface {
	GetAPIKey(ctx context.Context, in *GetAPIKeyRequest, opts ...grpc.CallOption) (*APIKeyResponse, error)
	// identify which sites meet the requirements of the queries
	Qualify(ctx context.Context, in *QualifyRequest, opts ...grpc.CallOption) (*QualifyResponse, error)
	// pull data from Mortar
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (Mortar_FetchClient, error)
}

MortarClient is the client API for Mortar service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMortarClient 

func NewMortarClient(cc *grpc.ClientConn) MortarClient

type MortarServer 

type MortarServer interface {
	GetAPIKey(context.Context, *GetAPIKeyRequest) (*APIKeyResponse, error)
	// identify which sites meet the requirements of the queries
	Qualify(context.Context, *QualifyRequest) (*QualifyResponse, error)
	// pull data from Mortar
	Fetch(*FetchRequest, Mortar_FetchServer) error
}

MortarServer is the server API for Mortar service.

type Mortar_FetchClient 

type Mortar_FetchClient interface {
	Recv() (*FetchResponse, error)
	grpc.ClientStream
}

type Mortar_FetchServer 

type Mortar_FetchServer interface {
	Send(*FetchResponse) error
	grpc.ServerStream
}

type QualifyRequest 

type QualifyRequest struct {
	// all of these queries must return a response for the site to be considered
	// qualified
	Required []string `protobuf:"bytes,1,rep,name=required,proto3" json:"required,omitempty"`
	// only one of these needs to return a response for the site to be
	// considered qualified
	Optional             []string `protobuf:"bytes,2,rep,name=optional,proto3" json:"optional,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QualifyRequest) Descriptor 

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

func (*QualifyRequest) GetOptional 

func (m *QualifyRequest) GetOptional() []string

func (*QualifyRequest) GetRequired 

func (m *QualifyRequest) GetRequired() []string

func (*QualifyRequest) ProtoMessage 

func (*QualifyRequest) ProtoMessage()

func (*QualifyRequest) Reset 

func (m *QualifyRequest) Reset()

func (*QualifyRequest) String 

func (m *QualifyRequest) String() string

func (*QualifyRequest) XXX_DiscardUnknown 

func (m *QualifyRequest) XXX_DiscardUnknown()

func (*QualifyRequest) XXX_Marshal 

func (m *QualifyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QualifyRequest) XXX_Merge 

func (m *QualifyRequest) XXX_Merge(src proto.Message)

func (*QualifyRequest) XXX_Size 

func (m *QualifyRequest) XXX_Size() int

func (*QualifyRequest) XXX_Unmarshal 

func (m *QualifyRequest) XXX_Unmarshal(b []byte) error

type QualifyResponse 

type QualifyResponse struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
	// list of sitenames
	Sites                []string `protobuf:"bytes,2,rep,name=sites,proto3" json:"sites,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QualifyResponse) Descriptor 

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

func (*QualifyResponse) GetError 

func (m *QualifyResponse) GetError() string

func (*QualifyResponse) GetSites 

func (m *QualifyResponse) GetSites() []string

func (*QualifyResponse) ProtoMessage 

func (*QualifyResponse) ProtoMessage()

func (*QualifyResponse) Reset 

func (m *QualifyResponse) Reset()

func (*QualifyResponse) String 

func (m *QualifyResponse) String() string

func (*QualifyResponse) XXX_DiscardUnknown 

func (m *QualifyResponse) XXX_DiscardUnknown()

func (*QualifyResponse) XXX_Marshal 

func (m *QualifyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QualifyResponse) XXX_Merge 

func (m *QualifyResponse) XXX_Merge(src proto.Message)

func (*QualifyResponse) XXX_Size 

func (m *QualifyResponse) XXX_Size() int

func (*QualifyResponse) XXX_Unmarshal 

func (m *QualifyResponse) XXX_Unmarshal(b []byte) error

type Row 

type Row struct {
	Values               []*URI   `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Row) Descriptor 

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

func (*Row) GetValues 

func (m *Row) GetValues() []*URI

func (*Row) ProtoMessage 

func (*Row) ProtoMessage()

func (*Row) Reset 

func (m *Row) Reset()

func (*Row) String 

func (m *Row) String() string

func (*Row) XXX_DiscardUnknown 

func (m *Row) XXX_DiscardUnknown()

func (*Row) XXX_Marshal 

func (m *Row) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Row) XXX_Merge 

func (m *Row) XXX_Merge(src proto.Message)

func (*Row) XXX_Size 

func (m *Row) XXX_Size() int

func (*Row) XXX_Unmarshal 

func (m *Row) XXX_Unmarshal(b []byte) error

type Stream 

type Stream struct {
	// name of the stream
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Brick query (alternative)
	Definition string   `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	DataVars   []string `protobuf:"bytes,6,rep,name=dataVars,proto3" json:"dataVars,omitempty"`
	// list of stream UUIDs
	Uuids []string `protobuf:"bytes,3,rep,name=uuids,proto3" json:"uuids,omitempty"`
	// aggregation function for this stream
	Aggregation AggFunc `protobuf:"varint,4,opt,name=aggregation,proto3,enum=mortar.AggFunc" json:"aggregation,omitempty"`
	// engineering units to convert the stream to
	Units                string   `protobuf:"bytes,5,opt,name=units,proto3" json:"units,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Stream) Descriptor 

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

func (*Stream) GetAggregation 

func (m *Stream) GetAggregation() AggFunc

func (*Stream) GetDataVars 

func (m *Stream) GetDataVars() []string

func (*Stream) GetDefinition 

func (m *Stream) GetDefinition() string

func (*Stream) GetName 

func (m *Stream) GetName() string

func (*Stream) GetUnits 

func (m *Stream) GetUnits() string

func (*Stream) GetUuids 

func (m *Stream) GetUuids() []string

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) XXX_DiscardUnknown 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal 

func (m *Stream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Stream) XXX_Merge 

func (m *Stream) XXX_Merge(src proto.Message)

func (*Stream) XXX_Size 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal 

func (m *Stream) XXX_Unmarshal(b []byte) error

type TimeParams 

type TimeParams struct {
	Start                string   `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	End                  string   `protobuf:"bytes,2,opt,name=end,proto3" json:"end,omitempty"`
	Window               string   `protobuf:"bytes,3,opt,name=window,proto3" json:"window,omitempty"`
	Aligned              bool     `protobuf:"varint,4,opt,name=aligned,proto3" json:"aligned,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TimeParams) Descriptor 

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

func (*TimeParams) GetAligned 

func (m *TimeParams) GetAligned() bool

func (*TimeParams) GetEnd 

func (m *TimeParams) GetEnd() string

func (*TimeParams) GetStart 

func (m *TimeParams) GetStart() string

func (*TimeParams) GetWindow 

func (m *TimeParams) GetWindow() string

func (*TimeParams) ProtoMessage 

func (*TimeParams) ProtoMessage()

func (*TimeParams) Reset 

func (m *TimeParams) Reset()

func (*TimeParams) String 

func (m *TimeParams) String() string

func (*TimeParams) XXX_DiscardUnknown 

func (m *TimeParams) XXX_DiscardUnknown()

func (*TimeParams) XXX_Marshal 

func (m *TimeParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeParams) XXX_Merge 

func (m *TimeParams) XXX_Merge(src proto.Message)

func (*TimeParams) XXX_Size 

func (m *TimeParams) XXX_Size() int

func (*TimeParams) XXX_Unmarshal 

func (m *TimeParams) XXX_Unmarshal(b []byte) error

type Timeseries 

type Timeseries struct {
	// name of the View
	View string `protobuf:"bytes,1,opt,name=view,proto3" json:"view,omitempty"`
	// list of variables from the view that
	// we want to get data for
	DataVars             []string `protobuf:"bytes,2,rep,name=dataVars,proto3" json:"dataVars,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Timeseries) Descriptor 

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

func (*Timeseries) GetDataVars 

func (m *Timeseries) GetDataVars() []string

func (*Timeseries) GetView 

func (m *Timeseries) GetView() string

func (*Timeseries) ProtoMessage 

func (*Timeseries) ProtoMessage()

func (*Timeseries) Reset 

func (m *Timeseries) Reset()

func (*Timeseries) String 

func (m *Timeseries) String() string

func (*Timeseries) XXX_DiscardUnknown 

func (m *Timeseries) XXX_DiscardUnknown()

func (*Timeseries) XXX_Marshal 

func (m *Timeseries) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Timeseries) XXX_Merge 

func (m *Timeseries) XXX_Merge(src proto.Message)

func (*Timeseries) XXX_Size 

func (m *Timeseries) XXX_Size() int

func (*Timeseries) XXX_Unmarshal 

func (m *Timeseries) XXX_Unmarshal(b []byte) error

type URI 

type URI struct {
	// full URI
	Namespace            string   `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*URI) Descriptor 

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

func (*URI) GetNamespace 

func (m *URI) GetNamespace() string

func (*URI) GetValue 

func (m *URI) GetValue() string

func (*URI) ProtoMessage 

func (*URI) ProtoMessage()

func (*URI) Reset 

func (m *URI) Reset()

func (*URI) String 

func (m *URI) String() string

func (*URI) XXX_DiscardUnknown 

func (m *URI) XXX_DiscardUnknown()

func (*URI) XXX_Marshal 

func (m *URI) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*URI) XXX_Merge 

func (m *URI) XXX_Merge(src proto.Message)

func (*URI) XXX_Size 

func (m *URI) XXX_Size() int

func (*URI) XXX_Unmarshal 

func (m *URI) XXX_Unmarshal(b []byte) error

type View 

type View struct {
	// name of the View
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// sites included in this View
	Sites []string `protobuf:"bytes,2,rep,name=sites,proto3" json:"sites,omitempty"`
	// brick query definition
	Definition           string   `protobuf:"bytes,3,opt,name=definition,proto3" json:"definition,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*View) Descriptor 

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

func (*View) GetDefinition 

func (m *View) GetDefinition() string

func (*View) GetName 

func (m *View) GetName() string

func (*View) GetSites 

func (m *View) GetSites() []string

func (*View) ProtoMessage 

func (*View) ProtoMessage()

func (*View) Reset 

func (m *View) Reset()

func (*View) String 

func (m *View) String() string

func (*View) XXX_DiscardUnknown 

func (m *View) XXX_DiscardUnknown()

func (*View) XXX_Marshal 

func (m *View) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*View) XXX_Merge 

func (m *View) XXX_Merge(src proto.Message)

func (*View) XXX_Size 

func (m *View) XXX_Size() int

func (*View) XXX_Unmarshal 

func (m *View) XXX_Unmarshal(b []byte) error

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.