Documentation
¶
Index ¶
- func RegisterSumServiceServer(s *grpc.Server, srv SumServiceServer)
- type ById
- func (*ById) Descriptor() ([]byte, []int)
- func (m *ById) GetId() uint64
- func (*ById) ProtoMessage()
- func (m *ById) Reset()
- func (m *ById) String() string
- func (m *ById) XXX_DiscardUnknown()
- func (m *ById) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ById) XXX_Merge(src proto.Message)
- func (m *ById) XXX_Size() int
- func (m *ById) XXX_Unmarshal(b []byte) error
- type ByMeta
- func (*ByMeta) Descriptor() ([]byte, []int)
- func (m *ByMeta) GetMeta() string
- func (m *ByMeta) GetValue() string
- func (*ByMeta) ProtoMessage()
- func (m *ByMeta) Reset()
- func (m *ByMeta) String() string
- func (m *ByMeta) XXX_DiscardUnknown()
- func (m *ByMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ByMeta) XXX_Merge(src proto.Message)
- func (m *ByMeta) XXX_Size() int
- func (m *ByMeta) XXX_Unmarshal(b []byte) error
- type ByName
- func (*ByName) Descriptor() ([]byte, []int)
- func (m *ByName) GetName() string
- func (*ByName) ProtoMessage()
- func (m *ByName) Reset()
- func (m *ByName) String() string
- func (m *ByName) XXX_DiscardUnknown()
- func (m *ByName) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ByName) XXX_Merge(src proto.Message)
- func (m *ByName) XXX_Size() int
- func (m *ByName) XXX_Unmarshal(b []byte) error
- type Call
- func (*Call) Descriptor() ([]byte, []int)
- func (m *Call) GetArgs() []string
- func (m *Call) GetOracleId() uint64
- func (*Call) ProtoMessage()
- func (m *Call) Reset()
- func (m *Call) String() string
- func (m *Call) XXX_DiscardUnknown()
- func (m *Call) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Call) XXX_Merge(src proto.Message)
- func (m *Call) XXX_Size() int
- func (m *Call) XXX_Unmarshal(b []byte) error
- type CallResponse
- func (*CallResponse) Descriptor() ([]byte, []int)
- func (m *CallResponse) GetData() *Data
- func (m *CallResponse) GetMsg() string
- func (m *CallResponse) GetSuccess() bool
- func (*CallResponse) ProtoMessage()
- func (m *CallResponse) Reset()
- func (m *CallResponse) String() string
- func (m *CallResponse) XXX_DiscardUnknown()
- func (m *CallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *CallResponse) XXX_Merge(src proto.Message)
- func (m *CallResponse) XXX_Size() int
- func (m *CallResponse) XXX_Unmarshal(b []byte) error
- type Data
- func (*Data) Descriptor() ([]byte, []int)
- func (m *Data) GetCompressed() bool
- func (m *Data) GetPayload() []byte
- func (*Data) ProtoMessage()
- func (m *Data) Reset()
- func (m *Data) String() string
- func (m *Data) XXX_DiscardUnknown()
- func (m *Data) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Data) XXX_Merge(src proto.Message)
- func (m *Data) XXX_Size() int
- func (m *Data) XXX_Unmarshal(b []byte) error
- type Empty
- func (*Empty) Descriptor() ([]byte, []int)
- func (*Empty) ProtoMessage()
- func (m *Empty) Reset()
- func (m *Empty) String() string
- func (m *Empty) XXX_DiscardUnknown()
- func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Empty) XXX_Merge(src proto.Message)
- func (m *Empty) XXX_Size() int
- func (m *Empty) XXX_Unmarshal(b []byte) error
- type FindResponse
- func (*FindResponse) Descriptor() ([]byte, []int)
- func (m *FindResponse) GetMsg() string
- func (m *FindResponse) GetRecords() []*Record
- func (m *FindResponse) GetSuccess() bool
- func (*FindResponse) ProtoMessage()
- func (m *FindResponse) Reset()
- func (m *FindResponse) String() string
- func (m *FindResponse) XXX_DiscardUnknown()
- func (m *FindResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindResponse) XXX_Merge(src proto.Message)
- func (m *FindResponse) XXX_Size() int
- func (m *FindResponse) XXX_Unmarshal(b []byte) error
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) GetPage() uint64
- func (m *ListRequest) GetPerPage() uint64
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) String() string
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type Oracle
- func (*Oracle) Descriptor() ([]byte, []int)
- func (m *Oracle) GetCode() string
- func (m *Oracle) GetId() uint64
- func (m *Oracle) GetName() string
- func (*Oracle) ProtoMessage()
- func (m *Oracle) Reset()
- func (m *Oracle) String() string
- func (m *Oracle) XXX_DiscardUnknown()
- func (m *Oracle) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Oracle) XXX_Merge(src proto.Message)
- func (m *Oracle) XXX_Size() int
- func (m *Oracle) XXX_Unmarshal(b []byte) error
- type OracleListResponse
- func (*OracleListResponse) Descriptor() ([]byte, []int)
- func (m *OracleListResponse) GetOracles() []*Oracle
- func (m *OracleListResponse) GetPages() uint64
- func (m *OracleListResponse) GetTotal() uint64
- func (*OracleListResponse) ProtoMessage()
- func (m *OracleListResponse) Reset()
- func (m *OracleListResponse) String() string
- func (m *OracleListResponse) XXX_DiscardUnknown()
- func (m *OracleListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OracleListResponse) XXX_Merge(src proto.Message)
- func (m *OracleListResponse) XXX_Size() int
- func (m *OracleListResponse) XXX_Unmarshal(b []byte) error
- type OracleResponse
- func (*OracleResponse) Descriptor() ([]byte, []int)
- func (m *OracleResponse) GetMsg() string
- func (m *OracleResponse) GetOracle() *Oracle
- func (m *OracleResponse) GetSuccess() bool
- func (*OracleResponse) ProtoMessage()
- func (m *OracleResponse) Reset()
- func (m *OracleResponse) String() string
- func (m *OracleResponse) XXX_DiscardUnknown()
- func (m *OracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *OracleResponse) XXX_Merge(src proto.Message)
- func (m *OracleResponse) XXX_Size() int
- func (m *OracleResponse) XXX_Unmarshal(b []byte) error
- type Record
- func (*Record) Descriptor() ([]byte, []int)
- func (m *Record) GetData() []float32
- func (m *Record) GetId() uint64
- func (m *Record) GetMeta() map[string]string
- func (*Record) ProtoMessage()
- func (m *Record) Reset()
- func (m *Record) String() string
- func (m *Record) XXX_DiscardUnknown()
- func (m *Record) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Record) XXX_Merge(src proto.Message)
- func (m *Record) XXX_Size() int
- func (m *Record) XXX_Unmarshal(b []byte) error
- type RecordListResponse
- func (*RecordListResponse) Descriptor() ([]byte, []int)
- func (m *RecordListResponse) GetPages() uint64
- func (m *RecordListResponse) GetRecords() []*Record
- func (m *RecordListResponse) GetTotal() uint64
- func (*RecordListResponse) ProtoMessage()
- func (m *RecordListResponse) Reset()
- func (m *RecordListResponse) String() string
- func (m *RecordListResponse) XXX_DiscardUnknown()
- func (m *RecordListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordListResponse) XXX_Merge(src proto.Message)
- func (m *RecordListResponse) XXX_Size() int
- func (m *RecordListResponse) XXX_Unmarshal(b []byte) error
- type RecordResponse
- func (*RecordResponse) Descriptor() ([]byte, []int)
- func (m *RecordResponse) GetMsg() string
- func (m *RecordResponse) GetRecord() *Record
- func (m *RecordResponse) GetSuccess() bool
- func (*RecordResponse) ProtoMessage()
- func (m *RecordResponse) Reset()
- func (m *RecordResponse) String() string
- func (m *RecordResponse) XXX_DiscardUnknown()
- func (m *RecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RecordResponse) XXX_Merge(src proto.Message)
- func (m *RecordResponse) XXX_Size() int
- func (m *RecordResponse) XXX_Unmarshal(b []byte) error
- type ServerInfo
- func (*ServerInfo) Descriptor() ([]byte, []int)
- func (m *ServerInfo) GetAddress() string
- func (m *ServerInfo) GetAlloc() uint64
- func (m *ServerInfo) GetArch() string
- func (m *ServerInfo) GetArgv() []string
- func (m *ServerInfo) GetCpus() uint64
- func (m *ServerInfo) GetCredspath() string
- func (m *ServerInfo) GetDatapath() string
- func (m *ServerInfo) GetGoVersion() string
- func (m *ServerInfo) GetGoroutines() uint64
- func (m *ServerInfo) GetMaxCpus() uint64
- func (m *ServerInfo) GetNumGc() uint64
- func (m *ServerInfo) GetOracles() uint64
- func (m *ServerInfo) GetOs() string
- func (m *ServerInfo) GetPid() uint64
- func (m *ServerInfo) GetRecords() uint64
- func (m *ServerInfo) GetSys() uint64
- func (m *ServerInfo) GetUid() uint64
- func (m *ServerInfo) GetUptime() uint64
- func (m *ServerInfo) GetVersion() string
- func (*ServerInfo) ProtoMessage()
- func (m *ServerInfo) Reset()
- func (m *ServerInfo) String() string
- func (m *ServerInfo) XXX_DiscardUnknown()
- func (m *ServerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServerInfo) XXX_Merge(src proto.Message)
- func (m *ServerInfo) XXX_Size() int
- func (m *ServerInfo) XXX_Unmarshal(b []byte) error
- type SumServiceClient
- type SumServiceServer
- type UnimplementedSumServiceServer
- func (*UnimplementedSumServiceServer) CreateOracle(ctx context.Context, req *Oracle) (*OracleResponse, error)
- func (*UnimplementedSumServiceServer) CreateRecord(ctx context.Context, req *Record) (*RecordResponse, error)
- func (*UnimplementedSumServiceServer) DeleteOracle(ctx context.Context, req *ById) (*OracleResponse, error)
- func (*UnimplementedSumServiceServer) DeleteRecord(ctx context.Context, req *ById) (*RecordResponse, error)
- func (*UnimplementedSumServiceServer) FindOracle(ctx context.Context, req *ByName) (*OracleResponse, error)
- func (*UnimplementedSumServiceServer) FindRecords(ctx context.Context, req *ByMeta) (*FindResponse, error)
- func (*UnimplementedSumServiceServer) Info(ctx context.Context, req *Empty) (*ServerInfo, error)
- func (*UnimplementedSumServiceServer) ListOracles(ctx context.Context, req *ListRequest) (*OracleListResponse, error)
- func (*UnimplementedSumServiceServer) ListRecords(ctx context.Context, req *ListRequest) (*RecordListResponse, error)
- func (*UnimplementedSumServiceServer) ReadOracle(ctx context.Context, req *ById) (*OracleResponse, error)
- func (*UnimplementedSumServiceServer) ReadRecord(ctx context.Context, req *ById) (*RecordResponse, error)
- func (*UnimplementedSumServiceServer) Run(ctx context.Context, req *Call) (*CallResponse, error)
- func (*UnimplementedSumServiceServer) UpdateOracle(ctx context.Context, req *Oracle) (*OracleResponse, error)
- func (*UnimplementedSumServiceServer) UpdateRecord(ctx context.Context, req *Record) (*RecordResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterSumServiceServer ¶
func RegisterSumServiceServer(s *grpc.Server, srv SumServiceServer)
Types ¶
type ById ¶
type ById struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ById) Descriptor ¶
func (*ById) ProtoMessage ¶
func (*ById) ProtoMessage()
func (*ById) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ById) XXX_DiscardUnknown()
func (*ById) XXX_Marshal ¶ added in v1.2.0
func (*ById) XXX_Unmarshal ¶ added in v1.2.0
type ByMeta ¶
type ByMeta struct {
Meta string `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,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 (*ByMeta) Descriptor ¶
func (*ByMeta) ProtoMessage ¶
func (*ByMeta) ProtoMessage()
func (*ByMeta) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ByMeta) XXX_DiscardUnknown()
func (*ByMeta) XXX_Marshal ¶ added in v1.2.0
func (*ByMeta) XXX_Unmarshal ¶ added in v1.2.0
type ByName ¶
type ByName struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ByName) Descriptor ¶
func (*ByName) ProtoMessage ¶
func (*ByName) ProtoMessage()
func (*ByName) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ByName) XXX_DiscardUnknown()
func (*ByName) XXX_Marshal ¶ added in v1.2.0
func (*ByName) XXX_Unmarshal ¶ added in v1.2.0
type Call ¶
type Call struct {
OracleId uint64 `protobuf:"varint,1,opt,name=oracle_id,json=oracleId,proto3" json:"oracle_id,omitempty"`
Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Call) Descriptor ¶
func (*Call) GetOracleId ¶
func (*Call) ProtoMessage ¶
func (*Call) ProtoMessage()
func (*Call) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Call) XXX_DiscardUnknown()
func (*Call) XXX_Marshal ¶ added in v1.2.0
func (*Call) XXX_Unmarshal ¶ added in v1.2.0
type CallResponse ¶
type CallResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
Data *Data `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*CallResponse) Descriptor ¶
func (*CallResponse) Descriptor() ([]byte, []int)
func (*CallResponse) GetData ¶
func (m *CallResponse) GetData() *Data
func (*CallResponse) GetMsg ¶
func (m *CallResponse) GetMsg() string
func (*CallResponse) GetSuccess ¶
func (m *CallResponse) GetSuccess() bool
func (*CallResponse) ProtoMessage ¶
func (*CallResponse) ProtoMessage()
func (*CallResponse) Reset ¶
func (m *CallResponse) Reset()
func (*CallResponse) String ¶
func (m *CallResponse) String() string
func (*CallResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *CallResponse) XXX_DiscardUnknown()
func (*CallResponse) XXX_Marshal ¶ added in v1.2.0
func (m *CallResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*CallResponse) XXX_Merge ¶ added in v1.2.0
func (m *CallResponse) XXX_Merge(src proto.Message)
func (*CallResponse) XXX_Size ¶ added in v1.2.0
func (m *CallResponse) XXX_Size() int
func (*CallResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *CallResponse) XXX_Unmarshal(b []byte) error
type Data ¶
type Data struct {
Compressed bool `protobuf:"varint,1,opt,name=compressed,proto3" json:"compressed,omitempty"`
Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Data) Descriptor ¶
func (*Data) GetCompressed ¶
func (*Data) GetPayload ¶
func (*Data) ProtoMessage ¶
func (*Data) ProtoMessage()
func (*Data) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Data) XXX_DiscardUnknown()
func (*Data) XXX_Marshal ¶ added in v1.2.0
func (*Data) XXX_Unmarshal ¶ added in v1.2.0
type Empty ¶
type Empty struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Empty) Descriptor ¶
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Empty) XXX_DiscardUnknown()
func (*Empty) XXX_Marshal ¶ added in v1.2.0
func (*Empty) XXX_Unmarshal ¶ added in v1.2.0
type FindResponse ¶
type FindResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
Records []*Record `protobuf:"bytes,3,rep,name=records,proto3" json:"records,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*FindResponse) Descriptor ¶
func (*FindResponse) Descriptor() ([]byte, []int)
func (*FindResponse) GetMsg ¶
func (m *FindResponse) GetMsg() string
func (*FindResponse) GetRecords ¶
func (m *FindResponse) GetRecords() []*Record
func (*FindResponse) GetSuccess ¶
func (m *FindResponse) GetSuccess() bool
func (*FindResponse) ProtoMessage ¶
func (*FindResponse) ProtoMessage()
func (*FindResponse) Reset ¶
func (m *FindResponse) Reset()
func (*FindResponse) String ¶
func (m *FindResponse) String() string
func (*FindResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *FindResponse) XXX_DiscardUnknown()
func (*FindResponse) XXX_Marshal ¶ added in v1.2.0
func (m *FindResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*FindResponse) XXX_Merge ¶ added in v1.2.0
func (m *FindResponse) XXX_Merge(src proto.Message)
func (*FindResponse) XXX_Size ¶ added in v1.2.0
func (m *FindResponse) XXX_Size() int
func (*FindResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *FindResponse) XXX_Unmarshal(b []byte) error
type ListRequest ¶
type ListRequest struct {
Page uint64 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
PerPage uint64 `protobuf:"varint,2,opt,name=per_page,json=perPage,proto3" json:"per_page,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) GetPage ¶
func (m *ListRequest) GetPage() uint64
func (*ListRequest) GetPerPage ¶
func (m *ListRequest) GetPerPage() uint64
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶ added in v1.2.0
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶ added in v1.2.0
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶ added in v1.2.0
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶ added in v1.2.0
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type Oracle ¶
type Oracle struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Code string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Oracle) Descriptor ¶
func (*Oracle) ProtoMessage ¶
func (*Oracle) ProtoMessage()
func (*Oracle) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Oracle) XXX_DiscardUnknown()
func (*Oracle) XXX_Marshal ¶ added in v1.2.0
func (*Oracle) XXX_Unmarshal ¶ added in v1.2.0
type OracleListResponse ¶ added in v1.2.0
type OracleListResponse struct {
Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
Pages uint64 `protobuf:"varint,2,opt,name=pages,proto3" json:"pages,omitempty"`
Oracles []*Oracle `protobuf:"bytes,3,rep,name=oracles,proto3" json:"oracles,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*OracleListResponse) Descriptor ¶ added in v1.2.0
func (*OracleListResponse) Descriptor() ([]byte, []int)
func (*OracleListResponse) GetOracles ¶ added in v1.2.0
func (m *OracleListResponse) GetOracles() []*Oracle
func (*OracleListResponse) GetPages ¶ added in v1.2.0
func (m *OracleListResponse) GetPages() uint64
func (*OracleListResponse) GetTotal ¶ added in v1.2.0
func (m *OracleListResponse) GetTotal() uint64
func (*OracleListResponse) ProtoMessage ¶ added in v1.2.0
func (*OracleListResponse) ProtoMessage()
func (*OracleListResponse) Reset ¶ added in v1.2.0
func (m *OracleListResponse) Reset()
func (*OracleListResponse) String ¶ added in v1.2.0
func (m *OracleListResponse) String() string
func (*OracleListResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *OracleListResponse) XXX_DiscardUnknown()
func (*OracleListResponse) XXX_Marshal ¶ added in v1.2.0
func (m *OracleListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OracleListResponse) XXX_Merge ¶ added in v1.2.0
func (m *OracleListResponse) XXX_Merge(src proto.Message)
func (*OracleListResponse) XXX_Size ¶ added in v1.2.0
func (m *OracleListResponse) XXX_Size() int
func (*OracleListResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *OracleListResponse) XXX_Unmarshal(b []byte) error
type OracleResponse ¶
type OracleResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
Oracle *Oracle `protobuf:"bytes,3,opt,name=oracle,proto3" json:"oracle,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*OracleResponse) Descriptor ¶
func (*OracleResponse) Descriptor() ([]byte, []int)
func (*OracleResponse) GetMsg ¶
func (m *OracleResponse) GetMsg() string
func (*OracleResponse) GetOracle ¶ added in v1.2.0
func (m *OracleResponse) GetOracle() *Oracle
func (*OracleResponse) GetSuccess ¶
func (m *OracleResponse) GetSuccess() bool
func (*OracleResponse) ProtoMessage ¶
func (*OracleResponse) ProtoMessage()
func (*OracleResponse) Reset ¶
func (m *OracleResponse) Reset()
func (*OracleResponse) String ¶
func (m *OracleResponse) String() string
func (*OracleResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *OracleResponse) XXX_DiscardUnknown()
func (*OracleResponse) XXX_Marshal ¶ added in v1.2.0
func (m *OracleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*OracleResponse) XXX_Merge ¶ added in v1.2.0
func (m *OracleResponse) XXX_Merge(src proto.Message)
func (*OracleResponse) XXX_Size ¶ added in v1.2.0
func (m *OracleResponse) XXX_Size() int
func (*OracleResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *OracleResponse) XXX_Unmarshal(b []byte) error
type Record ¶
type Record struct {
Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Data []float32 `protobuf:"fixed32,2,rep,packed,name=data,proto3" json:"data,omitempty"`
Meta map[string]string `` /* 149-byte string literal not displayed */
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*Record) Descriptor ¶
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *Record) XXX_DiscardUnknown()
func (*Record) XXX_Marshal ¶ added in v1.2.0
func (*Record) XXX_Unmarshal ¶ added in v1.2.0
type RecordListResponse ¶
type RecordListResponse struct {
Total uint64 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
Pages uint64 `protobuf:"varint,2,opt,name=pages,proto3" json:"pages,omitempty"`
Records []*Record `protobuf:"bytes,3,rep,name=records,proto3" json:"records,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RecordListResponse) Descriptor ¶
func (*RecordListResponse) Descriptor() ([]byte, []int)
func (*RecordListResponse) GetPages ¶
func (m *RecordListResponse) GetPages() uint64
func (*RecordListResponse) GetRecords ¶
func (m *RecordListResponse) GetRecords() []*Record
func (*RecordListResponse) GetTotal ¶
func (m *RecordListResponse) GetTotal() uint64
func (*RecordListResponse) ProtoMessage ¶
func (*RecordListResponse) ProtoMessage()
func (*RecordListResponse) Reset ¶
func (m *RecordListResponse) Reset()
func (*RecordListResponse) String ¶
func (m *RecordListResponse) String() string
func (*RecordListResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *RecordListResponse) XXX_DiscardUnknown()
func (*RecordListResponse) XXX_Marshal ¶ added in v1.2.0
func (m *RecordListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordListResponse) XXX_Merge ¶ added in v1.2.0
func (m *RecordListResponse) XXX_Merge(src proto.Message)
func (*RecordListResponse) XXX_Size ¶ added in v1.2.0
func (m *RecordListResponse) XXX_Size() int
func (*RecordListResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *RecordListResponse) XXX_Unmarshal(b []byte) error
type RecordResponse ¶
type RecordResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
Record *Record `protobuf:"bytes,3,opt,name=record,proto3" json:"record,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*RecordResponse) Descriptor ¶
func (*RecordResponse) Descriptor() ([]byte, []int)
func (*RecordResponse) GetMsg ¶
func (m *RecordResponse) GetMsg() string
func (*RecordResponse) GetRecord ¶
func (m *RecordResponse) GetRecord() *Record
func (*RecordResponse) GetSuccess ¶
func (m *RecordResponse) GetSuccess() bool
func (*RecordResponse) ProtoMessage ¶
func (*RecordResponse) ProtoMessage()
func (*RecordResponse) Reset ¶
func (m *RecordResponse) Reset()
func (*RecordResponse) String ¶
func (m *RecordResponse) String() string
func (*RecordResponse) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *RecordResponse) XXX_DiscardUnknown()
func (*RecordResponse) XXX_Marshal ¶ added in v1.2.0
func (m *RecordResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RecordResponse) XXX_Merge ¶ added in v1.2.0
func (m *RecordResponse) XXX_Merge(src proto.Message)
func (*RecordResponse) XXX_Size ¶ added in v1.2.0
func (m *RecordResponse) XXX_Size() int
func (*RecordResponse) XXX_Unmarshal ¶ added in v1.2.0
func (m *RecordResponse) XXX_Unmarshal(b []byte) error
type ServerInfo ¶
type ServerInfo struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
Os string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
Arch string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
GoVersion string `protobuf:"bytes,4,opt,name=go_version,json=goVersion,proto3" json:"go_version,omitempty"`
Cpus uint64 `protobuf:"varint,5,opt,name=cpus,proto3" json:"cpus,omitempty"`
MaxCpus uint64 `protobuf:"varint,6,opt,name=max_cpus,json=maxCpus,proto3" json:"max_cpus,omitempty"`
Goroutines uint64 `protobuf:"varint,7,opt,name=goroutines,proto3" json:"goroutines,omitempty"`
Alloc uint64 `protobuf:"varint,8,opt,name=alloc,proto3" json:"alloc,omitempty"`
Sys uint64 `protobuf:"varint,9,opt,name=sys,proto3" json:"sys,omitempty"`
NumGc uint64 `protobuf:"varint,10,opt,name=num_gc,json=numGc,proto3" json:"num_gc,omitempty"`
Datapath string `protobuf:"bytes,11,opt,name=datapath,proto3" json:"datapath,omitempty"`
Credspath string `protobuf:"bytes,12,opt,name=credspath,proto3" json:"credspath,omitempty"`
Address string `protobuf:"bytes,13,opt,name=address,proto3" json:"address,omitempty"`
Uptime uint64 `protobuf:"varint,14,opt,name=uptime,proto3" json:"uptime,omitempty"`
Pid uint64 `protobuf:"varint,15,opt,name=pid,proto3" json:"pid,omitempty"`
Uid uint64 `protobuf:"varint,16,opt,name=uid,proto3" json:"uid,omitempty"`
Argv []string `protobuf:"bytes,17,rep,name=argv,proto3" json:"argv,omitempty"`
Records uint64 `protobuf:"varint,18,opt,name=records,proto3" json:"records,omitempty"`
Oracles uint64 `protobuf:"varint,19,opt,name=oracles,proto3" json:"oracles,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (*ServerInfo) Descriptor ¶
func (*ServerInfo) Descriptor() ([]byte, []int)
func (*ServerInfo) GetAddress ¶ added in v1.2.0
func (m *ServerInfo) GetAddress() string
func (*ServerInfo) GetAlloc ¶ added in v1.2.0
func (m *ServerInfo) GetAlloc() uint64
func (*ServerInfo) GetArch ¶ added in v1.2.0
func (m *ServerInfo) GetArch() string
func (*ServerInfo) GetArgv ¶
func (m *ServerInfo) GetArgv() []string
func (*ServerInfo) GetCpus ¶ added in v1.2.0
func (m *ServerInfo) GetCpus() uint64
func (*ServerInfo) GetCredspath ¶ added in v1.2.0
func (m *ServerInfo) GetCredspath() string
func (*ServerInfo) GetDatapath ¶ added in v1.2.0
func (m *ServerInfo) GetDatapath() string
func (*ServerInfo) GetGoVersion ¶ added in v1.2.0
func (m *ServerInfo) GetGoVersion() string
func (*ServerInfo) GetGoroutines ¶ added in v1.2.0
func (m *ServerInfo) GetGoroutines() uint64
func (*ServerInfo) GetMaxCpus ¶ added in v1.2.0
func (m *ServerInfo) GetMaxCpus() uint64
func (*ServerInfo) GetNumGc ¶ added in v1.2.0
func (m *ServerInfo) GetNumGc() uint64
func (*ServerInfo) GetOracles ¶
func (m *ServerInfo) GetOracles() uint64
func (*ServerInfo) GetOs ¶ added in v1.2.0
func (m *ServerInfo) GetOs() string
func (*ServerInfo) GetPid ¶
func (m *ServerInfo) GetPid() uint64
func (*ServerInfo) GetRecords ¶
func (m *ServerInfo) GetRecords() uint64
func (*ServerInfo) GetSys ¶ added in v1.2.0
func (m *ServerInfo) GetSys() uint64
func (*ServerInfo) GetUid ¶
func (m *ServerInfo) GetUid() uint64
func (*ServerInfo) GetUptime ¶
func (m *ServerInfo) GetUptime() uint64
func (*ServerInfo) GetVersion ¶
func (m *ServerInfo) GetVersion() string
func (*ServerInfo) ProtoMessage ¶
func (*ServerInfo) ProtoMessage()
func (*ServerInfo) Reset ¶
func (m *ServerInfo) Reset()
func (*ServerInfo) String ¶
func (m *ServerInfo) String() string
func (*ServerInfo) XXX_DiscardUnknown ¶ added in v1.2.0
func (m *ServerInfo) XXX_DiscardUnknown()
func (*ServerInfo) XXX_Marshal ¶ added in v1.2.0
func (m *ServerInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ServerInfo) XXX_Merge ¶ added in v1.2.0
func (m *ServerInfo) XXX_Merge(src proto.Message)
func (*ServerInfo) XXX_Size ¶ added in v1.2.0
func (m *ServerInfo) XXX_Size() int
func (*ServerInfo) XXX_Unmarshal ¶ added in v1.2.0
func (m *ServerInfo) XXX_Unmarshal(b []byte) error
type SumServiceClient ¶
type SumServiceClient interface {
// vectors CRUD
CreateRecord(ctx context.Context, in *Record, opts ...grpc.CallOption) (*RecordResponse, error)
UpdateRecord(ctx context.Context, in *Record, opts ...grpc.CallOption) (*RecordResponse, error)
ReadRecord(ctx context.Context, in *ById, opts ...grpc.CallOption) (*RecordResponse, error)
ListRecords(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*RecordListResponse, error)
DeleteRecord(ctx context.Context, in *ById, opts ...grpc.CallOption) (*RecordResponse, error)
// find a vector given a meta name and value to filter for
FindRecords(ctx context.Context, in *ByMeta, opts ...grpc.CallOption) (*FindResponse, error)
// oracles CRUD
CreateOracle(ctx context.Context, in *Oracle, opts ...grpc.CallOption) (*OracleResponse, error)
UpdateOracle(ctx context.Context, in *Oracle, opts ...grpc.CallOption) (*OracleResponse, error)
ReadOracle(ctx context.Context, in *ById, opts ...grpc.CallOption) (*OracleResponse, error)
ListOracles(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*OracleListResponse, error)
FindOracle(ctx context.Context, in *ByName, opts ...grpc.CallOption) (*OracleResponse, error)
DeleteOracle(ctx context.Context, in *ById, opts ...grpc.CallOption) (*OracleResponse, error)
// execute a call to a oracle given its id
Run(ctx context.Context, in *Call, opts ...grpc.CallOption) (*CallResponse, error)
// get info about the service
Info(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ServerInfo, error)
}
SumServiceClient is the client API for SumService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewSumServiceClient ¶
func NewSumServiceClient(cc *grpc.ClientConn) SumServiceClient
type SumServiceServer ¶
type SumServiceServer interface {
// vectors CRUD
CreateRecord(context.Context, *Record) (*RecordResponse, error)
UpdateRecord(context.Context, *Record) (*RecordResponse, error)
ReadRecord(context.Context, *ById) (*RecordResponse, error)
ListRecords(context.Context, *ListRequest) (*RecordListResponse, error)
DeleteRecord(context.Context, *ById) (*RecordResponse, error)
// find a vector given a meta name and value to filter for
FindRecords(context.Context, *ByMeta) (*FindResponse, error)
// oracles CRUD
CreateOracle(context.Context, *Oracle) (*OracleResponse, error)
UpdateOracle(context.Context, *Oracle) (*OracleResponse, error)
ReadOracle(context.Context, *ById) (*OracleResponse, error)
ListOracles(context.Context, *ListRequest) (*OracleListResponse, error)
FindOracle(context.Context, *ByName) (*OracleResponse, error)
DeleteOracle(context.Context, *ById) (*OracleResponse, error)
// execute a call to a oracle given its id
Run(context.Context, *Call) (*CallResponse, error)
// get info about the service
Info(context.Context, *Empty) (*ServerInfo, error)
}
SumServiceServer is the server API for SumService service.
type UnimplementedSumServiceServer ¶ added in v1.2.0
type UnimplementedSumServiceServer struct {
}
UnimplementedSumServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedSumServiceServer) CreateOracle ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) CreateOracle(ctx context.Context, req *Oracle) (*OracleResponse, error)
func (*UnimplementedSumServiceServer) CreateRecord ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) CreateRecord(ctx context.Context, req *Record) (*RecordResponse, error)
func (*UnimplementedSumServiceServer) DeleteOracle ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) DeleteOracle(ctx context.Context, req *ById) (*OracleResponse, error)
func (*UnimplementedSumServiceServer) DeleteRecord ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) DeleteRecord(ctx context.Context, req *ById) (*RecordResponse, error)
func (*UnimplementedSumServiceServer) FindOracle ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) FindOracle(ctx context.Context, req *ByName) (*OracleResponse, error)
func (*UnimplementedSumServiceServer) FindRecords ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) FindRecords(ctx context.Context, req *ByMeta) (*FindResponse, error)
func (*UnimplementedSumServiceServer) Info ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) Info(ctx context.Context, req *Empty) (*ServerInfo, error)
func (*UnimplementedSumServiceServer) ListOracles ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) ListOracles(ctx context.Context, req *ListRequest) (*OracleListResponse, error)
func (*UnimplementedSumServiceServer) ListRecords ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) ListRecords(ctx context.Context, req *ListRequest) (*RecordListResponse, error)
func (*UnimplementedSumServiceServer) ReadOracle ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) ReadOracle(ctx context.Context, req *ById) (*OracleResponse, error)
func (*UnimplementedSumServiceServer) ReadRecord ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) ReadRecord(ctx context.Context, req *ById) (*RecordResponse, error)
func (*UnimplementedSumServiceServer) Run ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) Run(ctx context.Context, req *Call) (*CallResponse, error)
func (*UnimplementedSumServiceServer) UpdateOracle ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) UpdateOracle(ctx context.Context, req *Oracle) (*OracleResponse, error)
func (*UnimplementedSumServiceServer) UpdateRecord ¶ added in v1.2.0
func (*UnimplementedSumServiceServer) UpdateRecord(ctx context.Context, req *Record) (*RecordResponse, error)
Click to show internal directories.
Click to hide internal directories.