openinstrument_proto

package
v0.0.0-...-f53b987 Latest Latest
Warning

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

 Go to latest Published: Jul 22, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Overview

Package openinstrument_proto is a generated protocol buffer package.

It is generated from these files: 

proto/openinstrument.proto

It has these top-level messages: 

LogMessage
OperationLog
StreamVariable
StreamMutation
StreamAggregation
Value
ValueStream
Query
RetentionPolicyItem
RetentionPolicy
ClusterMember
ClusterConfig
Block
BlockHeaderIndex
BlockHeader
GetRequest
GetResponse
AddRequest
AddResponse
ListRequest
ListResponse
LookupBlockRequest
LookupBlockResponse
SplitBlockRequest
SplitBlockResponse
JoinBlockRequest
JoinBlockResponse
CompactBlockRequest
CompactBlockResponse
GetClusterRequest
GetClusterResponse
JoinClusterRequest
JoinClusterResponse
UpdateClusterRequest
UpdateClusterResponse
WatchClusterRequest
WatchClusterResponse
UpdateRetentionPolicyRequest
UpdateRetentionPolicyResponse

Index

Constants

This section is empty.

Variables

View Source 
var Block_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "LOADING",
	2: "LIVE",
	3: "COMPACTING",
	4: "MIGRATING",
	5: "UNLOADING",
	6: "UNLOADED",
	7: "DESTROYED",
}
View Source 
var Block_State_value = map[string]int32{
	"UNKNOWN":    0,
	"LOADING":    1,
	"LIVE":       2,
	"COMPACTING": 3,
	"MIGRATING":  4,
	"UNLOADING":  5,
	"UNLOADED":   6,
	"DESTROYED":  7,
}
View Source 
var ClusterMember_State_name = map[int32]string{
	0: "UNKNOWN",
	1: "LOAD",
	2: "RUN",
	3: "DRAIN",
	4: "READONLY",
	5: "SHUTDOWN",
}
View Source 
var ClusterMember_State_value = map[string]int32{
	"UNKNOWN":  0,
	"LOAD":     1,
	"RUN":      2,
	"DRAIN":    3,
	"READONLY": 4,
	"SHUTDOWN": 5,
}
View Source 
var RetentionPolicyItem_Target_name = map[int32]string{
	0: "KEEP",
	1: "DROP",
}
View Source 
var RetentionPolicyItem_Target_value = map[string]int32{
	"KEEP": 0,
	"DROP": 1,
}
View Source 
var StreamAggregation_AggregateType_name = map[int32]string{
	0: "NONE",
	1: "MEAN",
	2: "MAX",
	3: "MIN",
	4: "MEDIAN",
	5: "SUM",
	6: "STDDEV",
	7: "PERCENTILE",
}
View Source 
var StreamAggregation_AggregateType_value = map[string]int32{
	"NONE":       0,
	"MEAN":       1,
	"MAX":        2,
	"MIN":        3,
	"MEDIAN":     4,
	"SUM":        5,
	"STDDEV":     6,
	"PERCENTILE": 7,
}
View Source 
var StreamMutation_SampleType_name = map[int32]string{
	0:  "NONE",
	1:  "MEAN",
	2:  "MAX",
	3:  "MIN",
	4:  "RATE",
	5:  "RATE_SIGNED",
	6:  "INTERPOLATE",
	7:  "LAST",
	8:  "FIRST",
	9:  "MULTIPLY",
	10: "ADD",
	11: "ROOT",
	12: "POWER",
	13: "MOVING_AVERAGE",
}
View Source 
var StreamMutation_SampleType_value = map[string]int32{
	"NONE":           0,
	"MEAN":           1,
	"MAX":            2,
	"MIN":            3,
	"RATE":           4,
	"RATE_SIGNED":    5,
	"INTERPOLATE":    6,
	"LAST":           7,
	"FIRST":          8,
	"MULTIPLY":       9,
	"ADD":            10,
	"ROOT":           11,
	"POWER":          12,
	"MOVING_AVERAGE": 13,
}
View Source 
var UpdateRetentionPolicyRequest_Operation_name = map[int32]string{
	0: "UNKNOWN",
	1: "APPEND",
	2: "INSERT",
	3: "REMOVE",
}
View Source 
var UpdateRetentionPolicyRequest_Operation_value = map[string]int32{
	"UNKNOWN": 0,
	"APPEND":  1,
	"INSERT":  2,
	"REMOVE":  3,
}

Functions

func RegisterStoreServer 

func RegisterStoreServer(s *grpc.Server, srv StoreServer)

Types

type AddRequest 

type AddRequest struct {
	Stream []*ValueStream `protobuf:"bytes,1,rep,name=stream" json:"stream,omitempty"`
}

func (*AddRequest) Descriptor 

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

func (*AddRequest) GetStream 

func (m *AddRequest) GetStream() []*ValueStream

func (*AddRequest) ProtoMessage 

func (*AddRequest) ProtoMessage()

func (*AddRequest) Reset 

func (m *AddRequest) Reset()

func (*AddRequest) String 

func (m *AddRequest) String() string

type AddResponse 

type AddResponse struct {
	Success      bool          `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
	Errormessage string        `protobuf:"bytes,2,opt,name=errormessage" json:"errormessage,omitempty"`
	Timer        []*LogMessage `protobuf:"bytes,3,rep,name=timer" json:"timer,omitempty"`
	Streams      uint32        `protobuf:"varint,4,opt,name=streams" json:"streams,omitempty"`
	Values       uint32        `protobuf:"varint,5,opt,name=values" json:"values,omitempty"`
}

func (*AddResponse) Descriptor 

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

func (*AddResponse) GetTimer 

func (m *AddResponse) GetTimer() []*LogMessage

func (*AddResponse) ProtoMessage 

func (*AddResponse) ProtoMessage()

func (*AddResponse) Reset 

func (m *AddResponse) Reset()

func (*AddResponse) String 

func (m *AddResponse) String() string

type Block 

type Block struct {
	Header           *BlockHeader `protobuf:"bytes,17,opt,name=header" json:"header,omitempty"`
	Id               string       `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	EndKey           string       `protobuf:"bytes,2,opt,name=end_key" json:"end_key,omitempty"`
	State            Block_State  `protobuf:"varint,3,opt,name=state,enum=openinstrument.proto.Block_State" json:"state,omitempty"`
	IndexedStreams   uint32       `protobuf:"varint,4,opt,name=indexed_streams" json:"indexed_streams,omitempty"`
	IndexedValues    uint32       `protobuf:"varint,5,opt,name=indexed_values" json:"indexed_values,omitempty"`
	LoggedStreams    uint32       `protobuf:"varint,6,opt,name=logged_streams" json:"logged_streams,omitempty"`
	LoggedValues     uint32       `protobuf:"varint,7,opt,name=logged_values" json:"logged_values,omitempty"`
	UnloggedStreams  uint32       `protobuf:"varint,8,opt,name=unlogged_streams" json:"unlogged_streams,omitempty"`
	UnloggedValues   uint32       `protobuf:"varint,9,opt,name=unlogged_values" json:"unlogged_values,omitempty"`
	CompactDuration  string       `protobuf:"bytes,10,opt,name=compact_duration" json:"compact_duration,omitempty"`
	CompactStartTime uint64       `protobuf:"varint,11,opt,name=compact_start_time" json:"compact_start_time,omitempty"`
	CompactEndTime   uint64       `protobuf:"varint,12,opt,name=compact_end_time" json:"compact_end_time,omitempty"`
	Node             string       `protobuf:"bytes,13,opt,name=node" json:"node,omitempty"`
	DestinationNode  string       `protobuf:"bytes,14,opt,name=destination_node" json:"destination_node,omitempty"`
	LastUpdated      uint64       `protobuf:"varint,16,opt,name=last_updated" json:"last_updated,omitempty"`
	// Bytes
	Size uint32 `protobuf:"varint,18,opt,name=size" json:"size,omitempty"`
}

func (*Block) Descriptor 

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

func (*Block) GetHeader 

func (m *Block) GetHeader() *BlockHeader

func (*Block) ProtoMessage 

func (*Block) ProtoMessage()

func (*Block) Reset 

func (m *Block) Reset()

func (*Block) String 

func (m *Block) String() string

type BlockHeader 

type BlockHeader struct {
	Version        uint32              `protobuf:"varint,6,opt,name=version" json:"version,omitempty"`
	StartTimestamp uint64              `protobuf:"varint,1,opt,name=start_timestamp" json:"start_timestamp,omitempty"`
	EndTimestamp   uint64              `protobuf:"varint,2,opt,name=end_timestamp" json:"end_timestamp,omitempty"`
	Index          []*BlockHeaderIndex `protobuf:"bytes,5,rep,name=index" json:"index,omitempty"`
	EndKey         string              `protobuf:"bytes,7,opt,name=end_key" json:"end_key,omitempty"`
}

func (*BlockHeader) Descriptor 

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

func (*BlockHeader) GetIndex 

func (m *BlockHeader) GetIndex() []*BlockHeaderIndex

func (*BlockHeader) ProtoMessage 

func (*BlockHeader) ProtoMessage()

func (*BlockHeader) Reset 

func (m *BlockHeader) Reset()

func (*BlockHeader) String 

func (m *BlockHeader) String() string

type BlockHeaderIndex 

type BlockHeaderIndex struct {
	Variable     *StreamVariable `protobuf:"bytes,1,opt,name=variable" json:"variable,omitempty"`
	Offset       uint64          `protobuf:"fixed64,2,opt,name=offset" json:"offset,omitempty"`
	NumValues    uint32          `protobuf:"fixed32,3,opt,name=num_values" json:"num_values,omitempty"`
	MinTimestamp uint64          `protobuf:"fixed64,4,opt,name=min_timestamp" json:"min_timestamp,omitempty"`
	MaxTimestamp uint64          `protobuf:"fixed64,5,opt,name=max_timestamp" json:"max_timestamp,omitempty"`
}

func (*BlockHeaderIndex) Descriptor 

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

func (*BlockHeaderIndex) GetVariable 

func (m *BlockHeaderIndex) GetVariable() *StreamVariable

func (*BlockHeaderIndex) ProtoMessage 

func (*BlockHeaderIndex) ProtoMessage()

func (*BlockHeaderIndex) Reset 

func (m *BlockHeaderIndex) Reset()

func (*BlockHeaderIndex) String 

func (m *BlockHeaderIndex) String() string

type Block_State 

type Block_State int32
const (
	Block_UNKNOWN    Block_State = 0
	Block_LOADING    Block_State = 1
	Block_LIVE       Block_State = 2
	Block_COMPACTING Block_State = 3
	Block_MIGRATING  Block_State = 4
	Block_UNLOADING  Block_State = 5
	Block_UNLOADED   Block_State = 6
	Block_DESTROYED  Block_State = 7
)

func (Block_State) EnumDescriptor 

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

func (Block_State) String 

func (x Block_State) String() string

type ClusterConfig 

type ClusterConfig struct {
	Server          []*ClusterMember `protobuf:"bytes,1,rep,name=server" json:"server,omitempty"`
	Block           []*Block         `protobuf:"bytes,2,rep,name=block" json:"block,omitempty"`
	RetentionPolicy *RetentionPolicy `protobuf:"bytes,3,opt,name=retention_policy" json:"retention_policy,omitempty"`
}

func (*ClusterConfig) Descriptor 

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

func (*ClusterConfig) GetBlock 

func (m *ClusterConfig) GetBlock() []*Block

func (*ClusterConfig) GetRetentionPolicy 

func (m *ClusterConfig) GetRetentionPolicy() *RetentionPolicy

func (*ClusterConfig) GetServer 

func (m *ClusterConfig) GetServer() []*ClusterMember

func (*ClusterConfig) ProtoMessage 

func (*ClusterConfig) ProtoMessage()

func (*ClusterConfig) Reset 

func (m *ClusterConfig) Reset()

func (*ClusterConfig) String 

func (m *ClusterConfig) String() string

type ClusterMember 

type ClusterMember struct {
	Address     string              `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"`
	State       ClusterMember_State `protobuf:"varint,2,opt,name=state,enum=openinstrument.proto.ClusterMember_State" json:"state,omitempty"`
	LastUpdated uint64              `protobuf:"varint,3,opt,name=last_updated" json:"last_updated,omitempty"`
	Name        string              `protobuf:"bytes,4,opt,name=name" json:"name,omitempty"`
}

func (*ClusterMember) Descriptor 

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

func (*ClusterMember) ProtoMessage 

func (*ClusterMember) ProtoMessage()

func (*ClusterMember) Reset 

func (m *ClusterMember) Reset()

func (*ClusterMember) String 

func (m *ClusterMember) String() string

type ClusterMember_State 

type ClusterMember_State int32
const (
	ClusterMember_UNKNOWN  ClusterMember_State = 0
	ClusterMember_LOAD     ClusterMember_State = 1
	ClusterMember_RUN      ClusterMember_State = 2
	ClusterMember_DRAIN    ClusterMember_State = 3
	ClusterMember_READONLY ClusterMember_State = 4
	ClusterMember_SHUTDOWN ClusterMember_State = 5
)

func (ClusterMember_State) EnumDescriptor 

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

func (ClusterMember_State) String 

func (x ClusterMember_State) String() string

type CompactBlockRequest 

type CompactBlockRequest struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*CompactBlockRequest) Descriptor 

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

func (*CompactBlockRequest) GetBlock 

func (m *CompactBlockRequest) GetBlock() *Block

func (*CompactBlockRequest) ProtoMessage 

func (*CompactBlockRequest) ProtoMessage()

func (*CompactBlockRequest) Reset 

func (m *CompactBlockRequest) Reset()

func (*CompactBlockRequest) String 

func (m *CompactBlockRequest) String() string

type CompactBlockResponse 

type CompactBlockResponse struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*CompactBlockResponse) Descriptor 

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

func (*CompactBlockResponse) GetBlock 

func (m *CompactBlockResponse) GetBlock() *Block

func (*CompactBlockResponse) ProtoMessage 

func (*CompactBlockResponse) ProtoMessage()

func (*CompactBlockResponse) Reset 

func (m *CompactBlockResponse) Reset()

func (*CompactBlockResponse) String 

func (m *CompactBlockResponse) String() string

type GetClusterRequest 

type GetClusterRequest struct {
}

func (*GetClusterRequest) Descriptor 

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

func (*GetClusterRequest) ProtoMessage 

func (*GetClusterRequest) ProtoMessage()

func (*GetClusterRequest) Reset 

func (m *GetClusterRequest) Reset()

func (*GetClusterRequest) String 

func (m *GetClusterRequest) String() string

type GetClusterResponse 

type GetClusterResponse struct {
	Config *ClusterConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
}

func (*GetClusterResponse) Descriptor 

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

func (*GetClusterResponse) GetConfig 

func (m *GetClusterResponse) GetConfig() *ClusterConfig

func (*GetClusterResponse) ProtoMessage 

func (*GetClusterResponse) ProtoMessage()

func (*GetClusterResponse) Reset 

func (m *GetClusterResponse) Reset()

func (*GetClusterResponse) String 

func (m *GetClusterResponse) String() string

type GetRequest 

type GetRequest struct {
	Query *Query `protobuf:"bytes,1,opt,name=query" json:"query,omitempty"`
	// Limit to how many variables can be returned in a standard GetRequest. This can be overridden if required.
	MaxVariables uint32 `protobuf:"varint,2,opt,name=max_variables" json:"max_variables,omitempty"`
	// Limit the number of values that can be returned for each variable.
	MaxValues uint32 `protobuf:"varint,3,opt,name=max_values" json:"max_values,omitempty"`
}

func (*GetRequest) Descriptor 

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

func (*GetRequest) GetQuery 

func (m *GetRequest) GetQuery() *Query

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset 

func (m *GetRequest) Reset()

func (*GetRequest) String 

func (m *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
	Errormessage string `protobuf:"bytes,2,opt,name=errormessage" json:"errormessage,omitempty"`
	// Contains a separate stream for every mutation requested in GetRequest, in the same order. If no mutations are
	// requested, the response will contain a single stream of the raw data.
	Stream []*ValueStream `protobuf:"bytes,3,rep,name=stream" json:"stream,omitempty"`
	Timer  []*LogMessage  `protobuf:"bytes,4,rep,name=timer" json:"timer,omitempty"`
}

func (*GetResponse) Descriptor 

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

func (*GetResponse) GetStream 

func (m *GetResponse) GetStream() []*ValueStream

func (*GetResponse) GetTimer 

func (m *GetResponse) GetTimer() []*LogMessage

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset 

func (m *GetResponse) Reset()

func (*GetResponse) String 

func (m *GetResponse) String() string

type JoinBlockRequest 

type JoinBlockRequest struct {
	// This the last block in the sequence. The block with the previous end key
	// will be joined with this one, so the output block will have the same end
	// key, but a different ID.
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*JoinBlockRequest) Descriptor 

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

func (*JoinBlockRequest) GetBlock 

func (m *JoinBlockRequest) GetBlock() *Block

func (*JoinBlockRequest) ProtoMessage 

func (*JoinBlockRequest) ProtoMessage()

func (*JoinBlockRequest) Reset 

func (m *JoinBlockRequest) Reset()

func (*JoinBlockRequest) String 

func (m *JoinBlockRequest) String() string

type JoinBlockResponse 

type JoinBlockResponse struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*JoinBlockResponse) Descriptor 

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

func (*JoinBlockResponse) GetBlock 

func (m *JoinBlockResponse) GetBlock() *Block

func (*JoinBlockResponse) ProtoMessage 

func (*JoinBlockResponse) ProtoMessage()

func (*JoinBlockResponse) Reset 

func (m *JoinBlockResponse) Reset()

func (*JoinBlockResponse) String 

func (m *JoinBlockResponse) String() string

type JoinClusterRequest 

type JoinClusterRequest struct {
	Member *ClusterMember `protobuf:"bytes,1,opt,name=member" json:"member,omitempty"`
}

func (*JoinClusterRequest) Descriptor 

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

func (*JoinClusterRequest) GetMember 

func (m *JoinClusterRequest) GetMember() *ClusterMember

func (*JoinClusterRequest) ProtoMessage 

func (*JoinClusterRequest) ProtoMessage()

func (*JoinClusterRequest) Reset 

func (m *JoinClusterRequest) Reset()

func (*JoinClusterRequest) String 

func (m *JoinClusterRequest) String() string

type JoinClusterResponse 

type JoinClusterResponse struct {
	Member []*ClusterMember `protobuf:"bytes,1,rep,name=member" json:"member,omitempty"`
}

func (*JoinClusterResponse) Descriptor 

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

func (*JoinClusterResponse) GetMember 

func (m *JoinClusterResponse) GetMember() []*ClusterMember

func (*JoinClusterResponse) ProtoMessage 

func (*JoinClusterResponse) ProtoMessage()

func (*JoinClusterResponse) Reset 

func (m *JoinClusterResponse) Reset()

func (*JoinClusterResponse) String 

func (m *JoinClusterResponse) String() string

type ListRequest 

type ListRequest struct {
	Prefix *StreamVariable `protobuf:"bytes,1,opt,name=prefix" json:"prefix,omitempty"`
	// Limit to how many variables can be returned in a standard ListRequest. This can be overridden if required.
	MaxVariables uint32 `protobuf:"varint,2,opt,name=max_variables" json:"max_variables,omitempty"`
}

func (*ListRequest) Descriptor 

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

func (*ListRequest) GetPrefix 

func (m *ListRequest) GetPrefix() *StreamVariable

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset 

func (m *ListRequest) Reset()

func (*ListRequest) String 

func (m *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Success      bool   `protobuf:"varint,1,opt,name=success" json:"success,omitempty"`
	Errormessage string `protobuf:"bytes,2,opt,name=errormessage" json:"errormessage,omitempty"`
	// Although this uses the ValueStream for returning a list of variables, the expectation is that the value field is
	// empty.
	Stream   []*ValueStream    `protobuf:"bytes,3,rep,name=stream" json:"stream,omitempty"`
	Variable []*StreamVariable `protobuf:"bytes,4,rep,name=variable" json:"variable,omitempty"`
	Timer    []*LogMessage     `protobuf:"bytes,5,rep,name=timer" json:"timer,omitempty"`
}

func (*ListResponse) Descriptor 

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

func (*ListResponse) GetStream 

func (m *ListResponse) GetStream() []*ValueStream

func (*ListResponse) GetTimer 

func (m *ListResponse) GetTimer() []*LogMessage

func (*ListResponse) GetVariable 

func (m *ListResponse) GetVariable() []*StreamVariable

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset 

func (m *ListResponse) Reset()

func (*ListResponse) String 

func (m *ListResponse) String() string

type LogMessage 

type LogMessage struct {
	Timestamp    uint64 `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	EndTimestamp uint64 `protobuf:"varint,3,opt,name=end_timestamp" json:"end_timestamp,omitempty"`
	Message      string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
}

func (*LogMessage) Descriptor 

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

func (*LogMessage) ProtoMessage 

func (*LogMessage) ProtoMessage()

func (*LogMessage) Reset 

func (m *LogMessage) Reset()

func (*LogMessage) String 

func (m *LogMessage) String() string

type LookupBlockRequest 

type LookupBlockRequest struct {
	Variable *StreamVariable `protobuf:"bytes,1,opt,name=variable" json:"variable,omitempty"`
	BlockId  string          `protobuf:"bytes,2,opt,name=block_id" json:"block_id,omitempty"`
}

func (*LookupBlockRequest) Descriptor 

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

func (*LookupBlockRequest) GetVariable 

func (m *LookupBlockRequest) GetVariable() *StreamVariable

func (*LookupBlockRequest) ProtoMessage 

func (*LookupBlockRequest) ProtoMessage()

func (*LookupBlockRequest) Reset 

func (m *LookupBlockRequest) Reset()

func (*LookupBlockRequest) String 

func (m *LookupBlockRequest) String() string

type LookupBlockResponse 

type LookupBlockResponse struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*LookupBlockResponse) Descriptor 

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

func (*LookupBlockResponse) GetBlock 

func (m *LookupBlockResponse) GetBlock() *Block

func (*LookupBlockResponse) ProtoMessage 

func (*LookupBlockResponse) ProtoMessage()

func (*LookupBlockResponse) Reset 

func (m *LookupBlockResponse) Reset()

func (*LookupBlockResponse) String 

func (m *LookupBlockResponse) String() string

type OperationLog 

type OperationLog struct {
	Log []*LogMessage `protobuf:"bytes,1,rep,name=log" json:"log,omitempty"`
}

func (*OperationLog) Descriptor 

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

func (*OperationLog) GetLog 

func (m *OperationLog) GetLog() []*LogMessage

func (*OperationLog) ProtoMessage 

func (*OperationLog) ProtoMessage()

func (*OperationLog) Reset 

func (m *OperationLog) Reset()

func (*OperationLog) String 

func (m *OperationLog) String() string

type Query 

type Query struct {
	Variable    []*StreamVariable    `protobuf:"bytes,1,rep,name=variable" json:"variable,omitempty"`
	Mutation    []*StreamMutation    `protobuf:"bytes,2,rep,name=mutation" json:"mutation,omitempty"`
	Aggregation []*StreamAggregation `protobuf:"bytes,3,rep,name=aggregation" json:"aggregation,omitempty"`
	Constant    []float64            `protobuf:"fixed64,4,rep,name=constant" json:"constant,omitempty"`
}

Queries return a stream for every input variable / mutation / aggregation

func (*Query) Descriptor 

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

func (*Query) GetAggregation 

func (m *Query) GetAggregation() []*StreamAggregation

func (*Query) GetMutation 

func (m *Query) GetMutation() []*StreamMutation

func (*Query) GetVariable 

func (m *Query) GetVariable() []*StreamVariable

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) Reset 

func (m *Query) Reset()

func (*Query) String 

func (m *Query) String() string

type RetentionPolicy 

type RetentionPolicy struct {
	Policy   []*RetentionPolicyItem `protobuf:"bytes,1,rep,name=policy" json:"policy,omitempty"`
	Interval uint32                 `protobuf:"varint,2,opt,name=interval" json:"interval,omitempty"`
}

func (*RetentionPolicy) Descriptor 

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

func (*RetentionPolicy) GetPolicy 

func (m *RetentionPolicy) GetPolicy() []*RetentionPolicyItem

func (*RetentionPolicy) ProtoMessage 

func (*RetentionPolicy) ProtoMessage()

func (*RetentionPolicy) Reset 

func (m *RetentionPolicy) Reset()

func (*RetentionPolicy) String 

func (m *RetentionPolicy) String() string

type RetentionPolicyItem 

type RetentionPolicyItem struct {
	Variable []*StreamVariable          `protobuf:"bytes,1,rep,name=variable" json:"variable,omitempty"`
	Comment  []string                   `protobuf:"bytes,2,rep,name=comment" json:"comment,omitempty"`
	Policy   RetentionPolicyItem_Target `protobuf:"varint,3,opt,name=policy,enum=openinstrument.proto.RetentionPolicyItem_Target" json:"policy,omitempty"`
	Mutation []*StreamMutation          `protobuf:"bytes,4,rep,name=mutation" json:"mutation,omitempty"`
}

func (*RetentionPolicyItem) Descriptor 

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

func (*RetentionPolicyItem) GetMutation 

func (m *RetentionPolicyItem) GetMutation() []*StreamMutation

func (*RetentionPolicyItem) GetVariable 

func (m *RetentionPolicyItem) GetVariable() []*StreamVariable

func (*RetentionPolicyItem) ProtoMessage 

func (*RetentionPolicyItem) ProtoMessage()

func (*RetentionPolicyItem) Reset 

func (m *RetentionPolicyItem) Reset()

func (*RetentionPolicyItem) String 

func (m *RetentionPolicyItem) String() string

type RetentionPolicyItem_Target 

type RetentionPolicyItem_Target int32
const (
	RetentionPolicyItem_KEEP RetentionPolicyItem_Target = 0
	RetentionPolicyItem_DROP RetentionPolicyItem_Target = 1
)

func (RetentionPolicyItem_Target) EnumDescriptor 

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

func (RetentionPolicyItem_Target) String 

func (x RetentionPolicyItem_Target) String() string

type SplitBlockRequest 

type SplitBlockRequest struct {
	Block *Block `protobuf:"bytes,1,opt,name=block" json:"block,omitempty"`
}

func (*SplitBlockRequest) Descriptor 

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

func (*SplitBlockRequest) GetBlock 

func (m *SplitBlockRequest) GetBlock() *Block

func (*SplitBlockRequest) ProtoMessage 

func (*SplitBlockRequest) ProtoMessage()

func (*SplitBlockRequest) Reset 

func (m *SplitBlockRequest) Reset()

func (*SplitBlockRequest) String 

func (m *SplitBlockRequest) String() string

type SplitBlockResponse 

type SplitBlockResponse struct {
	Block []*Block `protobuf:"bytes,1,rep,name=block" json:"block,omitempty"`
}

func (*SplitBlockResponse) Descriptor 

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

func (*SplitBlockResponse) GetBlock 

func (m *SplitBlockResponse) GetBlock() []*Block

func (*SplitBlockResponse) ProtoMessage 

func (*SplitBlockResponse) ProtoMessage()

func (*SplitBlockResponse) Reset 

func (m *SplitBlockResponse) Reset()

func (*SplitBlockResponse) String 

func (m *SplitBlockResponse) String() string

type StoreClient 

type StoreClient interface {
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (Store_GetClient, error)
	Add(ctx context.Context, opts ...grpc.CallOption) (Store_AddClient, error)
	UpdateRetentionPolicy(ctx context.Context, in *UpdateRetentionPolicyRequest, opts ...grpc.CallOption) (*UpdateRetentionPolicyResponse, error)
	LookupBlock(ctx context.Context, in *LookupBlockRequest, opts ...grpc.CallOption) (*LookupBlockResponse, error)
	SplitBlock(ctx context.Context, in *SplitBlockRequest, opts ...grpc.CallOption) (*SplitBlockResponse, error)
	JoinBlock(ctx context.Context, in *JoinBlockRequest, opts ...grpc.CallOption) (*JoinBlockResponse, error)
	CompactBlock(ctx context.Context, in *CompactBlockRequest, opts ...grpc.CallOption) (*CompactBlockResponse, error)
	GetCluster(ctx context.Context, in *GetClusterRequest, opts ...grpc.CallOption) (*GetClusterResponse, error)
	WatchCluster(ctx context.Context, in *WatchClusterRequest, opts ...grpc.CallOption) (Store_WatchClusterClient, error)
}

func NewStoreClient 

func NewStoreClient(cc *grpc.ClientConn) StoreClient

type StoreServer 

type StoreServer interface {
	List(context.Context, *ListRequest) (*ListResponse, error)
	Get(*GetRequest, Store_GetServer) error
	Add(Store_AddServer) error
	UpdateRetentionPolicy(context.Context, *UpdateRetentionPolicyRequest) (*UpdateRetentionPolicyResponse, error)
	LookupBlock(context.Context, *LookupBlockRequest) (*LookupBlockResponse, error)
	SplitBlock(context.Context, *SplitBlockRequest) (*SplitBlockResponse, error)
	JoinBlock(context.Context, *JoinBlockRequest) (*JoinBlockResponse, error)
	CompactBlock(context.Context, *CompactBlockRequest) (*CompactBlockResponse, error)
	GetCluster(context.Context, *GetClusterRequest) (*GetClusterResponse, error)
	WatchCluster(*WatchClusterRequest, Store_WatchClusterServer) error
}

type Store_AddClient 

type Store_AddClient interface {
	Send(*AddRequest) error
	Recv() (*AddResponse, error)
	grpc.ClientStream
}

type Store_AddServer 

type Store_AddServer interface {
	Send(*AddResponse) error
	Recv() (*AddRequest, error)
	grpc.ServerStream
}

type Store_GetClient 

type Store_GetClient interface {
	Recv() (*GetResponse, error)
	grpc.ClientStream
}

type Store_GetServer 

type Store_GetServer interface {
	Send(*GetResponse) error
	grpc.ServerStream
}

type Store_WatchClusterClient 

type Store_WatchClusterClient interface {
	Recv() (*WatchClusterResponse, error)
	grpc.ClientStream
}

type Store_WatchClusterServer 

type Store_WatchClusterServer interface {
	Send(*WatchClusterResponse) error
	grpc.ServerStream
}

type StreamAggregation 

type StreamAggregation struct {
	Type StreamAggregation_AggregateType `protobuf:"varint,1,opt,name=type,enum=openinstrument.proto.StreamAggregation_AggregateType" json:"type,omitempty"`
	// Labels to aggregate by on the input streams. If no labels are specified, aggregation will be done on the variable
	// only.
	Label []string `protobuf:"bytes,2,rep,name=label" json:"label,omitempty"`
	// Points will be aggregated if they are less than sample_interval ms apart. Default is 30 seconds.
	SampleInterval uint32 `protobuf:"varint,3,opt,name=sample_interval" json:"sample_interval,omitempty"`
	// Optional parameter
	Param float64 `protobuf:"fixed64,4,opt,name=param" json:"param,omitempty"`
	// Input query
	Query []*Query `protobuf:"bytes,5,rep,name=query" json:"query,omitempty"`
}

Aggregations return a single output stream, built from the combination of every input query

func (*StreamAggregation) Descriptor 

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

func (*StreamAggregation) GetQuery 

func (m *StreamAggregation) GetQuery() []*Query

func (*StreamAggregation) ProtoMessage 

func (*StreamAggregation) ProtoMessage()

func (*StreamAggregation) Reset 

func (m *StreamAggregation) Reset()

func (*StreamAggregation) String 

func (m *StreamAggregation) String() string

type StreamAggregation_AggregateType 

type StreamAggregation_AggregateType int32
const (
	// Do not aggregate between streams
	StreamAggregation_NONE StreamAggregation_AggregateType = 0
	// Get the mean of all values at a common time across streams
	StreamAggregation_MEAN StreamAggregation_AggregateType = 1
	// Get the maximum of all values at a common time across streams
	StreamAggregation_MAX StreamAggregation_AggregateType = 2
	// Get the minimum of all values at a common time across streams
	StreamAggregation_MIN StreamAggregation_AggregateType = 3
	// Get the median of all values at a common time across streams
	StreamAggregation_MEDIAN StreamAggregation_AggregateType = 4
	// Get the total of all values at a common time across streams
	StreamAggregation_SUM StreamAggregation_AggregateType = 5
	// Get the standard deviation of all values at a common time across streams
	StreamAggregation_STDDEV StreamAggregation_AggregateType = 6
	// Get a particular percentile (provided in param) of all values at a common time across streams
	StreamAggregation_PERCENTILE StreamAggregation_AggregateType = 7
)

func (StreamAggregation_AggregateType) EnumDescriptor 

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

func (StreamAggregation_AggregateType) String 

func (x StreamAggregation_AggregateType) String() string

type StreamMutation 

type StreamMutation struct {
	Type  StreamMutation_SampleType `protobuf:"varint,1,opt,name=type,enum=openinstrument.proto.StreamMutation_SampleType" json:"type,omitempty"`
	Param float64                   `protobuf:"fixed64,2,opt,name=param" json:"param,omitempty"`
	// Input query
	Query *Query `protobuf:"bytes,3,opt,name=query" json:"query,omitempty"`
	// Gaps in the stream of more than <max_gap_interpolate> samples will not be filled.
	MaxGapInterpolate uint32 `protobuf:"varint,4,opt,name=max_gap_interpolate" json:"max_gap_interpolate,omitempty"`
	SampleFrequency   uint32 `protobuf:"varint,5,opt,name=sample_frequency" json:"sample_frequency,omitempty"`
}

Mutations return a modified copy of every input query

func (*StreamMutation) Descriptor 

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

func (*StreamMutation) GetQuery 

func (m *StreamMutation) GetQuery() *Query

func (*StreamMutation) ProtoMessage 

func (*StreamMutation) ProtoMessage()

func (*StreamMutation) Reset 

func (m *StreamMutation) Reset()

func (*StreamMutation) String 

func (m *StreamMutation) String() string

type StreamMutation_SampleType 

type StreamMutation_SampleType int32
const (
	// Do not modify the data at all
	StreamMutation_NONE StreamMutation_SampleType = 0
	// Average out values between each sampling point
	StreamMutation_MEAN StreamMutation_SampleType = 1
	// Get the maximum value between each sampling point
	StreamMutation_MAX StreamMutation_SampleType = 2
	// Get the minimum value between each sampling point
	StreamMutation_MIN StreamMutation_SampleType = 3
	// Get the positive rate between each sampling point
	StreamMutation_RATE StreamMutation_SampleType = 4
	// Get the (possibly) negative rate between each sampling point
	StreamMutation_RATE_SIGNED StreamMutation_SampleType = 5
	// Modify timestamps and values so that frequency (interval between consecutive samples) is constant (specify in param)
	// Extra values between each sample will be aggregated according to <sample_type>.
	// Gaps in the stream less than <max_gap_interpolate> samples will be filled with interpolated values between the
	// closest real values.
	StreamMutation_INTERPOLATE StreamMutation_SampleType = 6
	// Last point in a time bracket (specified in param)
	StreamMutation_LAST StreamMutation_SampleType = 7
	// First point in a time bracket (specified in param)
	StreamMutation_FIRST StreamMutation_SampleType = 8
	// Multiply all values by a constant (specify in param)
	StreamMutation_MULTIPLY StreamMutation_SampleType = 9
	// Add a constant to each value (specify in param)
	StreamMutation_ADD StreamMutation_SampleType = 10
	// Get the nth root of each value (specify in param)
	StreamMutation_ROOT StreamMutation_SampleType = 11
	// Get the nth power of each value (specify in param)
	StreamMutation_POWER StreamMutation_SampleType = 12
	// Moving average over a time period (specified in param)
	StreamMutation_MOVING_AVERAGE StreamMutation_SampleType = 13
)

func (StreamMutation_SampleType) EnumDescriptor 

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

func (StreamMutation_SampleType) String 

func (x StreamMutation_SampleType) String() string

type StreamVariable 

type StreamVariable struct {
	Name  string            `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Label map[string]string `` /* 130-byte string literal not displayed */
	// Milliseconds since epoch, or if negative, milliseconds before now.
	MinTimestamp int64 `protobuf:"varint,4,opt,name=min_timestamp" json:"min_timestamp,omitempty"`
	MaxTimestamp int64 `protobuf:"varint,5,opt,name=max_timestamp" json:"max_timestamp,omitempty"`
}

func (*StreamVariable) Descriptor 

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

func (*StreamVariable) GetLabel 

func (m *StreamVariable) GetLabel() map[string]string

func (*StreamVariable) ProtoMessage 

func (*StreamVariable) ProtoMessage()

func (*StreamVariable) Reset 

func (m *StreamVariable) Reset()

func (*StreamVariable) String 

func (m *StreamVariable) String() string

type UpdateClusterRequest 

type UpdateClusterRequest struct {
	Member []*ClusterMember `protobuf:"bytes,1,rep,name=member" json:"member,omitempty"`
}

func (*UpdateClusterRequest) Descriptor 

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

func (*UpdateClusterRequest) GetMember 

func (m *UpdateClusterRequest) GetMember() []*ClusterMember

func (*UpdateClusterRequest) ProtoMessage 

func (*UpdateClusterRequest) ProtoMessage()

func (*UpdateClusterRequest) Reset 

func (m *UpdateClusterRequest) Reset()

func (*UpdateClusterRequest) String 

func (m *UpdateClusterRequest) String() string

type UpdateClusterResponse 

type UpdateClusterResponse struct {
	Member []*ClusterMember `protobuf:"bytes,1,rep,name=member" json:"member,omitempty"`
}

func (*UpdateClusterResponse) Descriptor 

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

func (*UpdateClusterResponse) GetMember 

func (m *UpdateClusterResponse) GetMember() []*ClusterMember

func (*UpdateClusterResponse) ProtoMessage 

func (*UpdateClusterResponse) ProtoMessage()

func (*UpdateClusterResponse) Reset 

func (m *UpdateClusterResponse) Reset()

func (*UpdateClusterResponse) String 

func (m *UpdateClusterResponse) String() string

type UpdateRetentionPolicyRequest 

type UpdateRetentionPolicyRequest struct {
	Op   UpdateRetentionPolicyRequest_Operation `protobuf:"varint,1,opt,name=op,enum=openinstrument.proto.UpdateRetentionPolicyRequest_Operation" json:"op,omitempty"`
	Item *RetentionPolicyItem                   `protobuf:"bytes,2,opt,name=item" json:"item,omitempty"`
	// 0-indexed position for insert or remove
	Position uint32 `protobuf:"varint,3,opt,name=position" json:"position,omitempty"`
}

func (*UpdateRetentionPolicyRequest) Descriptor 

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

func (*UpdateRetentionPolicyRequest) GetItem 

func (m *UpdateRetentionPolicyRequest) GetItem() *RetentionPolicyItem

func (*UpdateRetentionPolicyRequest) ProtoMessage 

func (*UpdateRetentionPolicyRequest) ProtoMessage()

func (*UpdateRetentionPolicyRequest) Reset 

func (m *UpdateRetentionPolicyRequest) Reset()

func (*UpdateRetentionPolicyRequest) String 

func (m *UpdateRetentionPolicyRequest) String() string

type UpdateRetentionPolicyRequest_Operation 

type UpdateRetentionPolicyRequest_Operation int32
const (
	UpdateRetentionPolicyRequest_UNKNOWN UpdateRetentionPolicyRequest_Operation = 0
	UpdateRetentionPolicyRequest_APPEND  UpdateRetentionPolicyRequest_Operation = 1
	UpdateRetentionPolicyRequest_INSERT  UpdateRetentionPolicyRequest_Operation = 2
	UpdateRetentionPolicyRequest_REMOVE  UpdateRetentionPolicyRequest_Operation = 3
)

func (UpdateRetentionPolicyRequest_Operation) EnumDescriptor 

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

func (UpdateRetentionPolicyRequest_Operation) String 

func (x UpdateRetentionPolicyRequest_Operation) String() string

type UpdateRetentionPolicyResponse 

type UpdateRetentionPolicyResponse struct {
	Policy *RetentionPolicy `protobuf:"bytes,1,opt,name=policy" json:"policy,omitempty"`
}

func (*UpdateRetentionPolicyResponse) Descriptor 

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

func (*UpdateRetentionPolicyResponse) GetPolicy 

func (m *UpdateRetentionPolicyResponse) GetPolicy() *RetentionPolicy

func (*UpdateRetentionPolicyResponse) ProtoMessage 

func (*UpdateRetentionPolicyResponse) ProtoMessage()

func (*UpdateRetentionPolicyResponse) Reset 

func (m *UpdateRetentionPolicyResponse) Reset()

func (*UpdateRetentionPolicyResponse) String 

func (m *UpdateRetentionPolicyResponse) String() string

type Value 

type Value struct {
	// Milliseconds since epoch
	Timestamp uint64 `protobuf:"varint,1,opt,name=timestamp" json:"timestamp,omitempty"`
	// Types that are valid to be assigned to Value:
	//	*Value_Double
	//	*Value_String_
	Value isValue_Value `protobuf_oneof:"value"`
	// Used for run-length encoding
	EndTimestamp uint64 `protobuf:"varint,4,opt,name=end_timestamp" json:"end_timestamp,omitempty"`
}

func (*Value) Descriptor 

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

func (*Value) GetDouble 

func (m *Value) GetDouble() float64

func (*Value) GetString_ 

func (m *Value) GetString_() string

func (*Value) GetValue 

func (m *Value) GetValue() isValue_Value

func (*Value) ProtoMessage 

func (*Value) ProtoMessage()

func (*Value) Reset 

func (m *Value) Reset()

func (*Value) String 

func (m *Value) String() string

func (*Value) XXX_OneofFuncs 

func (*Value) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

type ValueStream 

type ValueStream struct {
	Variable *StreamVariable `protobuf:"bytes,2,opt,name=variable" json:"variable,omitempty"`
	Value    []*Value        `protobuf:"bytes,4,rep,name=value" json:"value,omitempty"`
}

func (*ValueStream) Descriptor 

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

func (*ValueStream) GetValue 

func (m *ValueStream) GetValue() []*Value

func (*ValueStream) GetVariable 

func (m *ValueStream) GetVariable() *StreamVariable

func (*ValueStream) ProtoMessage 

func (*ValueStream) ProtoMessage()

func (*ValueStream) Reset 

func (m *ValueStream) Reset()

func (*ValueStream) String 

func (m *ValueStream) String() string

type Value_Double 

type Value_Double struct {
	Double float64 `protobuf:"fixed64,2,opt,name=double,oneof"`
}

type Value_String_ 

type Value_String_ struct {
	String_ string `protobuf:"bytes,3,opt,name=string,oneof"`
}

type WatchClusterRequest 

type WatchClusterRequest struct {
}

func (*WatchClusterRequest) Descriptor 

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

func (*WatchClusterRequest) ProtoMessage 

func (*WatchClusterRequest) ProtoMessage()

func (*WatchClusterRequest) Reset 

func (m *WatchClusterRequest) Reset()

func (*WatchClusterRequest) String 

func (m *WatchClusterRequest) String() string

type WatchClusterResponse 

type WatchClusterResponse struct {
	Config *ClusterConfig `protobuf:"bytes,1,opt,name=config" json:"config,omitempty"`
}

func (*WatchClusterResponse) Descriptor 

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

func (*WatchClusterResponse) GetConfig 

func (m *WatchClusterResponse) GetConfig() *ClusterConfig

func (*WatchClusterResponse) ProtoMessage 

func (*WatchClusterResponse) ProtoMessage()

func (*WatchClusterResponse) Reset 

func (m *WatchClusterResponse) Reset()

func (*WatchClusterResponse) String 

func (m *WatchClusterResponse) 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.