pb

package
v0.0.0-...-9ea754e Latest Latest
Warning

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

 Go to latest Published: Apr 13, 2017 License: GPL-3.0 Imports: 12 Imported by: 0

Documentation

Overview

Package pb is a generated protocol buffer package.

It is generated from these files: 

api.proto
records.proto

It has these top-level messages: 

CounterValues
RecordCounterRequest
RecordCounterResponse
BulkRecordCounterRequest
BulkRecordCounterResponse
GetCounterRequest
GetCounterResponse
RecordKey
RecordEntry
RecordBlock

Package pb is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterQueryCounterServiceHandler 

func RegisterQueryCounterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryCounterServiceHandler registers the http handlers for service QueryCounterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryCounterServiceHandlerFromEndpoint 

func RegisterQueryCounterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryCounterServiceHandlerFromEndpoint is same as RegisterQueryCounterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryCounterServiceServer 

func RegisterQueryCounterServiceServer(s *grpc.Server, srv QueryCounterServiceServer)

func RegisterRecordCounterServiceHandler 

func RegisterRecordCounterServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRecordCounterServiceHandler registers the http handlers for service RecordCounterService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRecordCounterServiceHandlerFromEndpoint 

func RegisterRecordCounterServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRecordCounterServiceHandlerFromEndpoint is same as RegisterRecordCounterServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRecordCounterServiceServer 

func RegisterRecordCounterServiceServer(s *grpc.Server, srv RecordCounterServiceServer)

Types

type BulkRecordCounterRequest 

type BulkRecordCounterRequest struct {
	Requests []*RecordCounterRequest `protobuf:"bytes,1,rep,name=requests" json:"requests,omitempty"`
}

func (*BulkRecordCounterRequest) Descriptor 

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

func (*BulkRecordCounterRequest) GetRequests 

func (m *BulkRecordCounterRequest) GetRequests() []*RecordCounterRequest

func (*BulkRecordCounterRequest) ProtoMessage 

func (*BulkRecordCounterRequest) ProtoMessage()

func (*BulkRecordCounterRequest) Reset 

func (m *BulkRecordCounterRequest) Reset()

func (*BulkRecordCounterRequest) String 

func (m *BulkRecordCounterRequest) String() string

type BulkRecordCounterResponse 

type BulkRecordCounterResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*BulkRecordCounterResponse) Descriptor 

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

func (*BulkRecordCounterResponse) GetError 

func (m *BulkRecordCounterResponse) GetError() string

func (*BulkRecordCounterResponse) GetOk 

func (m *BulkRecordCounterResponse) GetOk() bool

func (*BulkRecordCounterResponse) ProtoMessage 

func (*BulkRecordCounterResponse) ProtoMessage()

func (*BulkRecordCounterResponse) Reset 

func (m *BulkRecordCounterResponse) Reset()

func (*BulkRecordCounterResponse) String 

func (m *BulkRecordCounterResponse) String() string

type CounterValues 

type CounterValues struct {
	Count int32   `protobuf:"varint,1,opt,name=count" json:"count,omitempty"`
	Sum   float32 `protobuf:"fixed32,2,opt,name=sum" json:"sum,omitempty"`
	Min   float32 `protobuf:"fixed32,3,opt,name=min" json:"min,omitempty"`
	Max   float32 `protobuf:"fixed32,4,opt,name=max" json:"max,omitempty"`
}

func (*CounterValues) Descriptor 

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

func (*CounterValues) GetCount 

func (m *CounterValues) GetCount() int32

func (*CounterValues) GetMax 

func (m *CounterValues) GetMax() float32

func (*CounterValues) GetMin 

func (m *CounterValues) GetMin() float32

func (*CounterValues) GetSum 

func (m *CounterValues) GetSum() float32

func (*CounterValues) ProtoMessage 

func (*CounterValues) ProtoMessage()

func (*CounterValues) Reset 

func (m *CounterValues) Reset()

func (*CounterValues) String 

func (m *CounterValues) String() string

type GetCounterRequest 

type GetCounterRequest struct {
	Name             string `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Source           string `protobuf:"bytes,2,opt,name=source" json:"source,omitempty"`
	StartEpochMinute int32  `protobuf:"varint,3,opt,name=startEpochMinute" json:"startEpochMinute,omitempty"`
	EndEpochMinute   int32  `protobuf:"varint,4,opt,name=endEpochMinute" json:"endEpochMinute,omitempty"`
}

func (*GetCounterRequest) Descriptor 

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

func (*GetCounterRequest) GetEndEpochMinute 

func (m *GetCounterRequest) GetEndEpochMinute() int32

func (*GetCounterRequest) GetName 

func (m *GetCounterRequest) GetName() string

func (*GetCounterRequest) GetSource 

func (m *GetCounterRequest) GetSource() string

func (*GetCounterRequest) GetStartEpochMinute 

func (m *GetCounterRequest) GetStartEpochMinute() int32

func (*GetCounterRequest) ProtoMessage 

func (*GetCounterRequest) ProtoMessage()

func (*GetCounterRequest) Reset 

func (m *GetCounterRequest) Reset()

func (*GetCounterRequest) String 

func (m *GetCounterRequest) String() string

type GetCounterResponse 

type GetCounterResponse struct {
	Ok     bool                     `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	Error  string                   `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
	Values map[int32]*CounterValues `` /* 133-byte string literal not displayed */
}

func (*GetCounterResponse) Descriptor 

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

func (*GetCounterResponse) GetError 

func (m *GetCounterResponse) GetError() string

func (*GetCounterResponse) GetOk 

func (m *GetCounterResponse) GetOk() bool

func (*GetCounterResponse) GetValues 

func (m *GetCounterResponse) GetValues() map[int32]*CounterValues

func (*GetCounterResponse) ProtoMessage 

func (*GetCounterResponse) ProtoMessage()

func (*GetCounterResponse) Reset 

func (m *GetCounterResponse) Reset()

func (*GetCounterResponse) String 

func (m *GetCounterResponse) String() string

type QueryCounterServiceClient 

type QueryCounterServiceClient interface {
	GetCounter(ctx context.Context, in *GetCounterRequest, opts ...grpc.CallOption) (*GetCounterResponse, error)
}

func NewQueryCounterServiceClient 

func NewQueryCounterServiceClient(cc *grpc.ClientConn) QueryCounterServiceClient

type QueryCounterServiceServer 

type QueryCounterServiceServer interface {
	GetCounter(context.Context, *GetCounterRequest) (*GetCounterResponse, error)
}

type RecordBlock 

type RecordBlock struct {
	NameCodeMapping   map[int32]string `` /* 151-byte string literal not displayed */
	SourceCodeMapping map[int32]string `` /* 155-byte string literal not displayed */
	Entries           []*RecordEntry   `protobuf:"bytes,3,rep,name=entries" json:"entries,omitempty"`
}

func (*RecordBlock) Descriptor 

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

func (*RecordBlock) GetEntries 

func (m *RecordBlock) GetEntries() []*RecordEntry

func (*RecordBlock) GetNameCodeMapping 

func (m *RecordBlock) GetNameCodeMapping() map[int32]string

func (*RecordBlock) GetSourceCodeMapping 

func (m *RecordBlock) GetSourceCodeMapping() map[int32]string

func (*RecordBlock) ProtoMessage 

func (*RecordBlock) ProtoMessage()

func (*RecordBlock) Reset 

func (m *RecordBlock) Reset()

func (*RecordBlock) String 

func (m *RecordBlock) String() string

type RecordCounterRequest 

type RecordCounterRequest struct {
	Name        string         `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	Source      string         `protobuf:"bytes,2,opt,name=source" json:"source,omitempty"`
	EpochMinute int32          `protobuf:"varint,3,opt,name=epochMinute" json:"epochMinute,omitempty"`
	Values      *CounterValues `protobuf:"bytes,4,opt,name=values" json:"values,omitempty"`
}

func (*RecordCounterRequest) Descriptor 

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

func (*RecordCounterRequest) GetEpochMinute 

func (m *RecordCounterRequest) GetEpochMinute() int32

func (*RecordCounterRequest) GetName 

func (m *RecordCounterRequest) GetName() string

func (*RecordCounterRequest) GetSource 

func (m *RecordCounterRequest) GetSource() string

func (*RecordCounterRequest) GetValues 

func (m *RecordCounterRequest) GetValues() *CounterValues

func (*RecordCounterRequest) ProtoMessage 

func (*RecordCounterRequest) ProtoMessage()

func (*RecordCounterRequest) Reset 

func (m *RecordCounterRequest) Reset()

func (*RecordCounterRequest) String 

func (m *RecordCounterRequest) String() string

type RecordCounterResponse 

type RecordCounterResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error" json:"error,omitempty"`
}

func (*RecordCounterResponse) Descriptor 

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

func (*RecordCounterResponse) GetError 

func (m *RecordCounterResponse) GetError() string

func (*RecordCounterResponse) GetOk 

func (m *RecordCounterResponse) GetOk() bool

func (*RecordCounterResponse) ProtoMessage 

func (*RecordCounterResponse) ProtoMessage()

func (*RecordCounterResponse) Reset 

func (m *RecordCounterResponse) Reset()

func (*RecordCounterResponse) String 

func (m *RecordCounterResponse) String() string

type RecordCounterServiceClient 

type RecordCounterServiceClient interface {
	RecordCounter(ctx context.Context, in *RecordCounterRequest, opts ...grpc.CallOption) (*RecordCounterResponse, error)
	BulkRecordCounter(ctx context.Context, in *BulkRecordCounterRequest, opts ...grpc.CallOption) (*BulkRecordCounterResponse, error)
}

func NewRecordCounterServiceClient 

func NewRecordCounterServiceClient(cc *grpc.ClientConn) RecordCounterServiceClient

type RecordCounterServiceServer 

type RecordCounterServiceServer interface {
	RecordCounter(context.Context, *RecordCounterRequest) (*RecordCounterResponse, error)
	BulkRecordCounter(context.Context, *BulkRecordCounterRequest) (*BulkRecordCounterResponse, error)
}

type RecordEntry 

type RecordEntry struct {
	Key    *RecordKey     `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Values *CounterValues `protobuf:"bytes,2,opt,name=values" json:"values,omitempty"`
}

func (*RecordEntry) Descriptor 

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

func (*RecordEntry) GetKey 

func (m *RecordEntry) GetKey() *RecordKey

func (*RecordEntry) GetValues 

func (m *RecordEntry) GetValues() *CounterValues

func (*RecordEntry) ProtoMessage 

func (*RecordEntry) ProtoMessage()

func (*RecordEntry) Reset 

func (m *RecordEntry) Reset()

func (*RecordEntry) String 

func (m *RecordEntry) String() string

type RecordKey 

type RecordKey struct {
	NameCode    int32 `protobuf:"varint,1,opt,name=nameCode" json:"nameCode,omitempty"`
	SourceCode  int32 `protobuf:"varint,2,opt,name=sourceCode" json:"sourceCode,omitempty"`
	EpochMinute int32 `protobuf:"varint,3,opt,name=epochMinute" json:"epochMinute,omitempty"`
}

func (*RecordKey) Descriptor 

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

func (*RecordKey) GetEpochMinute 

func (m *RecordKey) GetEpochMinute() int32

func (*RecordKey) GetNameCode 

func (m *RecordKey) GetNameCode() int32

func (*RecordKey) GetSourceCode 

func (m *RecordKey) GetSourceCode() int32

func (*RecordKey) ProtoMessage 

func (*RecordKey) ProtoMessage()

func (*RecordKey) Reset 

func (m *RecordKey) Reset()

func (*RecordKey) String 

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