_go

package
v1.0.0-beta.12 Latest Latest
Warning

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

 Go to latest Published: Jul 2, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DenormMask_name = map[int32]string{
	0:  "None",
	1:  "FName",
	2:  "FTime",
	4:  "FUnit",
	8:  "FValue",
	16: "FSum",
}
View Source 
var DenormMask_value = map[string]int32{
	"None":   0,
	"FName":  1,
	"FTime":  2,
	"FUnit":  4,
	"FValue": 8,
	"FSum":   16,
}
View Source 
var Series_ValueType_name = map[int32]string{
	0: "Float",
	1: "String",
	2: "Bool",
	3: "Data",
}
View Source 
var Series_ValueType_value = map[string]int32{
	"Float":  0,
	"String": 1,
	"Bool":   2,
	"Data":   3,
}

Functions

func RegisterDataServer 

func RegisterDataServer(s *grpc.Server, srv DataServer)

func RegisterRegistryServer 

func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)

Types

type CountResponse 

type CountResponse struct {
	Total                int32    `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountResponse) Descriptor 

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

func (*CountResponse) GetTotal 

func (m *CountResponse) GetTotal() int32

func (*CountResponse) ProtoMessage 

func (*CountResponse) ProtoMessage()

func (*CountResponse) Reset 

func (m *CountResponse) Reset()

func (*CountResponse) String 

func (m *CountResponse) String() string

func (*CountResponse) XXX_DiscardUnknown 

func (m *CountResponse) XXX_DiscardUnknown()

func (*CountResponse) XXX_Marshal 

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

func (*CountResponse) XXX_Merge 

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

func (*CountResponse) XXX_Size 

func (m *CountResponse) XXX_Size() int

func (*CountResponse) XXX_Unmarshal 

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

type DataClient 

type DataClient interface {
	Submit(ctx context.Context, opts ...grpc.CallOption) (Data_SubmitClient, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (Data_QueryClient, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Data_SubscribeClient, error)
	Count(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*CountResponse, error)
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*Void, error)
}

DataClient is the client API for Data service.

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

func NewDataClient 

func NewDataClient(cc grpc.ClientConnInterface) DataClient

type DataServer 

type DataServer interface {
	Submit(Data_SubmitServer) error
	Query(*QueryRequest, Data_QueryServer) error
	Subscribe(*SubscribeRequest, Data_SubscribeServer) error
	Count(context.Context, *QueryRequest) (*CountResponse, error)
	Delete(context.Context, *DeleteRequest) (*Void, error)
}

DataServer is the server API for Data service.

type Data_QueryClient 

type Data_QueryClient interface {
	Recv() (*_go.Message, error)
	grpc.ClientStream
}

type Data_QueryServer 

type Data_QueryServer interface {
	Send(*_go.Message) error
	grpc.ServerStream
}

type Data_SubmitClient 

type Data_SubmitClient interface {
	Send(*_go.Message) error
	CloseAndRecv() (*Void, error)
	grpc.ClientStream
}

type Data_SubmitServer 

type Data_SubmitServer interface {
	SendAndClose(*Void) error
	Recv() (*_go.Message, error)
	grpc.ServerStream
}

type Data_SubscribeClient 

type Data_SubscribeClient interface {
	Recv() (*_go.Message, error)
	grpc.ClientStream
}

type Data_SubscribeServer 

type Data_SubscribeServer interface {
	Send(*_go.Message) error
	grpc.ServerStream
}

type DeleteRequest 

type DeleteRequest struct {
	Series               []string `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	From                 string   `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To                   string   `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteRequest) Descriptor 

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

func (*DeleteRequest) GetFrom 

func (m *DeleteRequest) GetFrom() string

func (*DeleteRequest) GetSeries 

func (m *DeleteRequest) GetSeries() []string

func (*DeleteRequest) GetTo 

func (m *DeleteRequest) GetTo() string

func (*DeleteRequest) ProtoMessage 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (m *DeleteRequest) String() string

func (*DeleteRequest) XXX_DiscardUnknown 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal 

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

func (*DeleteRequest) XXX_Merge 

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

func (*DeleteRequest) XXX_Size 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal 

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

type DenormMask 

type DenormMask int32

The denormalization mask sp 

const (
	//No value is denormalized
	DenormMask_None   DenormMask = 0
	DenormMask_FName  DenormMask = 1
	DenormMask_FTime  DenormMask = 2
	DenormMask_FUnit  DenormMask = 4
	DenormMask_FValue DenormMask = 8
	DenormMask_FSum   DenormMask = 16
)

func (DenormMask) EnumDescriptor 

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

func (DenormMask) String 

func (x DenormMask) String() string

type FilterManyRequest 

type FilterManyRequest struct {
	FilterPath           *Filterpath `protobuf:"bytes,1,opt,name=filterPath,proto3" json:"filterPath,omitempty"`
	PageParams           *PageParams `protobuf:"bytes,2,opt,name=pageParams,proto3" json:"pageParams,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*FilterManyRequest) Descriptor 

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

func (*FilterManyRequest) GetFilterPath 

func (m *FilterManyRequest) GetFilterPath() *Filterpath

func (*FilterManyRequest) GetPageParams 

func (m *FilterManyRequest) GetPageParams() *PageParams

func (*FilterManyRequest) ProtoMessage 

func (*FilterManyRequest) ProtoMessage()

func (*FilterManyRequest) Reset 

func (m *FilterManyRequest) Reset()

func (*FilterManyRequest) String 

func (m *FilterManyRequest) String() string

func (*FilterManyRequest) XXX_DiscardUnknown 

func (m *FilterManyRequest) XXX_DiscardUnknown()

func (*FilterManyRequest) XXX_Marshal 

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

func (*FilterManyRequest) XXX_Merge 

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

func (*FilterManyRequest) XXX_Size 

func (m *FilterManyRequest) XXX_Size() int

func (*FilterManyRequest) XXX_Unmarshal 

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

type Filterpath 

type Filterpath struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Op                   string   `protobuf:"bytes,2,opt,name=op,proto3" json:"op,omitempty"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Filterpath) Descriptor 

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

func (*Filterpath) GetOp 

func (m *Filterpath) GetOp() string

func (*Filterpath) GetPath 

func (m *Filterpath) GetPath() string

func (*Filterpath) GetValue 

func (m *Filterpath) GetValue() string

func (*Filterpath) ProtoMessage 

func (*Filterpath) ProtoMessage()

func (*Filterpath) Reset 

func (m *Filterpath) Reset()

func (*Filterpath) String 

func (m *Filterpath) String() string

func (*Filterpath) XXX_DiscardUnknown 

func (m *Filterpath) XXX_DiscardUnknown()

func (*Filterpath) XXX_Marshal 

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

func (*Filterpath) XXX_Merge 

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

func (*Filterpath) XXX_Size 

func (m *Filterpath) XXX_Size() int

func (*Filterpath) XXX_Unmarshal 

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

type PageParams 

type PageParams struct {
	Page                 int32    `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PerPage              int32    `protobuf:"varint,2,opt,name=perPage,proto3" json:"perPage,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PageParams) Descriptor 

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

func (*PageParams) GetPage 

func (m *PageParams) GetPage() int32

func (*PageParams) GetPerPage 

func (m *PageParams) GetPerPage() int32

func (*PageParams) ProtoMessage 

func (*PageParams) ProtoMessage()

func (*PageParams) Reset 

func (m *PageParams) Reset()

func (*PageParams) String 

func (m *PageParams) String() string

func (*PageParams) XXX_DiscardUnknown 

func (m *PageParams) XXX_DiscardUnknown()

func (*PageParams) XXX_Marshal 

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

func (*PageParams) XXX_Merge 

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

func (*PageParams) XXX_Size 

func (m *PageParams) XXX_Size() int

func (*PageParams) XXX_Unmarshal 

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

type QueryRequest 

type QueryRequest struct {
	Series               []string   `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	From                 string     `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	To                   string     `protobuf:"bytes,3,opt,name=to,proto3" json:"to,omitempty"`
	RecordPerPacket      int32      `protobuf:"varint,5,opt,name=recordPerPacket,proto3" json:"recordPerPacket,omitempty"`
	DenormaMask          DenormMask `protobuf:"varint,6,opt,name=denormaMask,proto3,enum=data.DenormMask" json:"denormaMask,omitempty"`
	SortAsc              bool       `protobuf:"varint,7,opt,name=sort_asc,json=sortAsc,proto3" json:"sort_asc,omitempty"`
	Limit                int32      `protobuf:"varint,8,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32      `protobuf:"varint,9,opt,name=offset,proto3" json:"offset,omitempty"`
	Aggregator           string     `protobuf:"bytes,10,opt,name=aggregator,proto3" json:"aggregator,omitempty"`
	AggrInterval         string     `protobuf:"bytes,11,opt,name=aggrInterval,proto3" json:"aggrInterval,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*QueryRequest) Descriptor 

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

func (*QueryRequest) GetAggrInterval 

func (m *QueryRequest) GetAggrInterval() string

func (*QueryRequest) GetAggregator 

func (m *QueryRequest) GetAggregator() string

func (*QueryRequest) GetDenormaMask 

func (m *QueryRequest) GetDenormaMask() DenormMask

func (*QueryRequest) GetFrom 

func (m *QueryRequest) GetFrom() string

func (*QueryRequest) GetLimit 

func (m *QueryRequest) GetLimit() int32

func (*QueryRequest) GetOffset 

func (m *QueryRequest) GetOffset() int32

func (*QueryRequest) GetRecordPerPacket 

func (m *QueryRequest) GetRecordPerPacket() int32

func (*QueryRequest) GetSeries 

func (m *QueryRequest) GetSeries() []string

func (*QueryRequest) GetSortAsc 

func (m *QueryRequest) GetSortAsc() bool

func (*QueryRequest) GetTo 

func (m *QueryRequest) GetTo() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset 

func (m *QueryRequest) Reset()

func (*QueryRequest) String 

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown 

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal 

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

func (*QueryRequest) XXX_Merge 

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

func (*QueryRequest) XXX_Size 

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal 

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

type Registrations 

type Registrations struct {
	SeriesList           []*Series `protobuf:"bytes,1,rep,name=seriesList,proto3" json:"seriesList,omitempty"`
	Total                int32     `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Page                 int32     `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	PerPage              int32     `protobuf:"varint,4,opt,name=perPage,proto3" json:"perPage,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*Registrations) Descriptor 

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

func (*Registrations) GetPage 

func (m *Registrations) GetPage() int32

func (*Registrations) GetPerPage 

func (m *Registrations) GetPerPage() int32

func (*Registrations) GetSeriesList 

func (m *Registrations) GetSeriesList() []*Series

func (*Registrations) GetTotal 

func (m *Registrations) GetTotal() int32

func (*Registrations) ProtoMessage 

func (*Registrations) ProtoMessage()

func (*Registrations) Reset 

func (m *Registrations) Reset()

func (*Registrations) String 

func (m *Registrations) String() string

func (*Registrations) XXX_DiscardUnknown 

func (m *Registrations) XXX_DiscardUnknown()

func (*Registrations) XXX_Marshal 

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

func (*Registrations) XXX_Merge 

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

func (*Registrations) XXX_Size 

func (m *Registrations) XXX_Size() int

func (*Registrations) XXX_Unmarshal 

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

type RegistryClient 

type RegistryClient interface {
	Add(ctx context.Context, in *Series, opts ...grpc.CallOption) (*Void, error)
	GetAll(ctx context.Context, in *PageParams, opts ...grpc.CallOption) (*Registrations, error)
	Get(ctx context.Context, in *SeriesName, opts ...grpc.CallOption) (*Series, error)
	FilterOne(ctx context.Context, in *Filterpath, opts ...grpc.CallOption) (*Series, error)
	Filter(ctx context.Context, in *FilterManyRequest, opts ...grpc.CallOption) (*Registrations, error)
	Update(ctx context.Context, in *Series, opts ...grpc.CallOption) (*Void, error)
	Delete(ctx context.Context, in *SeriesName, opts ...grpc.CallOption) (*Void, error)
}

RegistryClient is the client API for Registry service.

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

func NewRegistryClient 

func NewRegistryClient(cc grpc.ClientConnInterface) RegistryClient

type RegistryServer 

type RegistryServer interface {
	Add(context.Context, *Series) (*Void, error)
	GetAll(context.Context, *PageParams) (*Registrations, error)
	Get(context.Context, *SeriesName) (*Series, error)
	FilterOne(context.Context, *Filterpath) (*Series, error)
	Filter(context.Context, *FilterManyRequest) (*Registrations, error)
	Update(context.Context, *Series) (*Void, error)
	Delete(context.Context, *SeriesName) (*Void, error)
}

RegistryServer is the server API for Registry service.

type Series 

type Series struct {
	Name                 string           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type                 Series_ValueType `protobuf:"varint,2,opt,name=type,proto3,enum=data.Series_ValueType" json:"type,omitempty"`
	Unit                 string           `protobuf:"bytes,3,opt,name=unit,proto3" json:"unit,omitempty"`
	Meta                 *_struct.Struct  `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*Series) Descriptor 

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

func (*Series) GetMeta 

func (m *Series) GetMeta() *_struct.Struct

func (*Series) GetName 

func (m *Series) GetName() string

func (*Series) GetType 

func (m *Series) GetType() Series_ValueType

func (*Series) GetUnit 

func (m *Series) GetUnit() string

func (*Series) ProtoMessage 

func (*Series) ProtoMessage()

func (*Series) Reset 

func (m *Series) Reset()

func (*Series) String 

func (m *Series) String() string

func (*Series) XXX_DiscardUnknown 

func (m *Series) XXX_DiscardUnknown()

func (*Series) XXX_Marshal 

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

func (*Series) XXX_Merge 

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

func (*Series) XXX_Size 

func (m *Series) XXX_Size() int

func (*Series) XXX_Unmarshal 

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

type SeriesName 

type SeriesName struct {
	Series               string   `protobuf:"bytes,1,opt,name=series,proto3" json:"series,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeriesName) Descriptor 

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

func (*SeriesName) GetSeries 

func (m *SeriesName) GetSeries() string

func (*SeriesName) ProtoMessage 

func (*SeriesName) ProtoMessage()

func (*SeriesName) Reset 

func (m *SeriesName) Reset()

func (*SeriesName) String 

func (m *SeriesName) String() string

func (*SeriesName) XXX_DiscardUnknown 

func (m *SeriesName) XXX_DiscardUnknown()

func (*SeriesName) XXX_Marshal 

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

func (*SeriesName) XXX_Merge 

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

func (*SeriesName) XXX_Size 

func (m *SeriesName) XXX_Size() int

func (*SeriesName) XXX_Unmarshal 

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

type Series_ValueType 

type Series_ValueType int32
const (
	Series_Float  Series_ValueType = 0
	Series_String Series_ValueType = 1
	Series_Bool   Series_ValueType = 2
	Series_Data   Series_ValueType = 3
)

func (Series_ValueType) EnumDescriptor 

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

func (Series_ValueType) String 

func (x Series_ValueType) String() string

type SubscribeRequest 

type SubscribeRequest struct {
	Series               []string `protobuf:"bytes,1,rep,name=series,proto3" json:"series,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetSeries 

func (m *SubscribeRequest) GetSeries() []string

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type UnimplementedDataServer 

type UnimplementedDataServer struct {
}

UnimplementedDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataServer) Count 

func (*UnimplementedDataServer) Count(ctx context.Context, req *QueryRequest) (*CountResponse, error)

func (*UnimplementedDataServer) Delete 

func (*UnimplementedDataServer) Delete(ctx context.Context, req *DeleteRequest) (*Void, error)

func (*UnimplementedDataServer) Query 

func (*UnimplementedDataServer) Query(req *QueryRequest, srv Data_QueryServer) error

func (*UnimplementedDataServer) Submit 

func (*UnimplementedDataServer) Submit(srv Data_SubmitServer) error

func (*UnimplementedDataServer) Subscribe 

func (*UnimplementedDataServer) Subscribe(req *SubscribeRequest, srv Data_SubscribeServer) error

type UnimplementedRegistryServer 

type UnimplementedRegistryServer struct {
}

UnimplementedRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedRegistryServer) Add 

func (*UnimplementedRegistryServer) Add(ctx context.Context, req *Series) (*Void, error)

func (*UnimplementedRegistryServer) Delete 

func (*UnimplementedRegistryServer) Delete(ctx context.Context, req *SeriesName) (*Void, error)

func (*UnimplementedRegistryServer) Filter 

func (*UnimplementedRegistryServer) Filter(ctx context.Context, req *FilterManyRequest) (*Registrations, error)

func (*UnimplementedRegistryServer) FilterOne 

func (*UnimplementedRegistryServer) FilterOne(ctx context.Context, req *Filterpath) (*Series, error)

func (*UnimplementedRegistryServer) Get 

func (*UnimplementedRegistryServer) Get(ctx context.Context, req *SeriesName) (*Series, error)

func (*UnimplementedRegistryServer) GetAll 

func (*UnimplementedRegistryServer) GetAll(ctx context.Context, req *PageParams) (*Registrations, error)

func (*UnimplementedRegistryServer) Update 

func (*UnimplementedRegistryServer) Update(ctx context.Context, req *Series) (*Void, error)

type Void 

type Void struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Void) Descriptor 

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

func (*Void) ProtoMessage 

func (*Void) ProtoMessage()

func (*Void) Reset 

func (m *Void) Reset()

func (*Void) String 

func (m *Void) String() string

func (*Void) XXX_DiscardUnknown 

func (m *Void) XXX_DiscardUnknown()

func (*Void) XXX_Marshal 

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

func (*Void) XXX_Merge 

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

func (*Void) XXX_Size 

func (m *Void) XXX_Size() int

func (*Void) XXX_Unmarshal 

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