Documentation ¶
Index ¶
- Variables
- func RegisterOracleServiceServer(s *grpc.Server, srv OracleServiceServer)
- type DataSourcesResponse
- func (*DataSourcesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DataSourcesResponse) GetCurrentValue() uint64
- func (x *DataSourcesResponse) GetDescription() string
- func (x *DataSourcesResponse) GetId() uint64
- func (x *DataSourcesResponse) GetName() string
- func (x *DataSourcesResponse) GetValueError() string
- func (*DataSourcesResponse) ProtoMessage()
- func (x *DataSourcesResponse) ProtoReflect() protoreflect.Message
- func (x *DataSourcesResponse) Reset()
- func (x *DataSourcesResponse) String() string
- type OracleServiceClient
- type OracleServiceServer
- type OracleService_DataSourcesClient
- type OracleService_DataSourcesServer
- type OracleService_PublicationsClient
- type OracleService_PublicationsServer
- type PubKeyResponse
- type PublicationRequest
- func (*PublicationRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublicationRequest) GetRPoint() string
- func (*PublicationRequest) ProtoMessage()
- func (x *PublicationRequest) ProtoReflect() protoreflect.Message
- func (x *PublicationRequest) Reset()
- func (x *PublicationRequest) String() string
- type PublicationResponse
- func (*PublicationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublicationResponse) GetName() string
- func (x *PublicationResponse) GetSignature() string
- func (x *PublicationResponse) GetTimestamp() uint64
- func (x *PublicationResponse) GetValue() uint64
- func (*PublicationResponse) ProtoMessage()
- func (x *PublicationResponse) ProtoReflect() protoreflect.Message
- func (x *PublicationResponse) Reset()
- func (x *PublicationResponse) String() string
- type PublicationsRequest
- func (*PublicationsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublicationsRequest) GetBase() string
- func (x *PublicationsRequest) GetQuote() string
- func (*PublicationsRequest) ProtoMessage()
- func (x *PublicationsRequest) ProtoReflect() protoreflect.Message
- func (x *PublicationsRequest) Reset()
- func (x *PublicationsRequest) String() string
- type RPointRequest
- func (*RPointRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RPointRequest) GetId() uint64
- func (x *RPointRequest) GetTimestamp() int64
- func (*RPointRequest) ProtoMessage()
- func (x *RPointRequest) ProtoReflect() protoreflect.Message
- func (x *RPointRequest) Reset()
- func (x *RPointRequest) String() string
- type RPointResponse
- type UnimplementedOracleServiceServer
- func (*UnimplementedOracleServiceServer) DataSources(*empty.Empty, OracleService_DataSourcesServer) error
- func (*UnimplementedOracleServiceServer) PubKey(context.Context, *empty.Empty) (*PubKeyResponse, error)
- func (*UnimplementedOracleServiceServer) Publication(context.Context, *PublicationRequest) (*PublicationResponse, error)
- func (*UnimplementedOracleServiceServer) Publications(*PublicationsRequest, OracleService_PublicationsServer) error
- func (*UnimplementedOracleServiceServer) RPoint(context.Context, *RPointRequest) (*RPointResponse, error)
Constants ¶
This section is empty.
Variables ¶
var File_rpc_protobuf_oracle_proto protoreflect.FileDescriptor
Functions ¶
func RegisterOracleServiceServer ¶
func RegisterOracleServiceServer(s *grpc.Server, srv OracleServiceServer)
Types ¶
type DataSourcesResponse ¶
type DataSourcesResponse struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` Id uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"` CurrentValue uint64 `protobuf:"varint,4,opt,name=current_value,json=currentValue,proto3" json:"current_value,omitempty"` ValueError string `protobuf:"bytes,5,opt,name=value_error,json=valueError,proto3" json:"value_error,omitempty"` // contains filtered or unexported fields }
func (*DataSourcesResponse) Descriptor
deprecated
func (*DataSourcesResponse) Descriptor() ([]byte, []int)
Deprecated: Use DataSourcesResponse.ProtoReflect.Descriptor instead.
func (*DataSourcesResponse) GetCurrentValue ¶
func (x *DataSourcesResponse) GetCurrentValue() uint64
func (*DataSourcesResponse) GetDescription ¶
func (x *DataSourcesResponse) GetDescription() string
func (*DataSourcesResponse) GetId ¶
func (x *DataSourcesResponse) GetId() uint64
func (*DataSourcesResponse) GetName ¶
func (x *DataSourcesResponse) GetName() string
func (*DataSourcesResponse) GetValueError ¶
func (x *DataSourcesResponse) GetValueError() string
func (*DataSourcesResponse) ProtoMessage ¶
func (*DataSourcesResponse) ProtoMessage()
func (*DataSourcesResponse) ProtoReflect ¶
func (x *DataSourcesResponse) ProtoReflect() protoreflect.Message
func (*DataSourcesResponse) Reset ¶
func (x *DataSourcesResponse) Reset()
func (*DataSourcesResponse) String ¶
func (x *DataSourcesResponse) String() string
type OracleServiceClient ¶
type OracleServiceClient interface { PubKey(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*PubKeyResponse, error) DataSources(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (OracleService_DataSourcesClient, error) RPoint(ctx context.Context, in *RPointRequest, opts ...grpc.CallOption) (*RPointResponse, error) Publication(ctx context.Context, in *PublicationRequest, opts ...grpc.CallOption) (*PublicationResponse, error) Publications(ctx context.Context, in *PublicationsRequest, opts ...grpc.CallOption) (OracleService_PublicationsClient, error) }
OracleServiceClient is the client API for OracleService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOracleServiceClient ¶
func NewOracleServiceClient(cc grpc.ClientConnInterface) OracleServiceClient
type OracleServiceServer ¶
type OracleServiceServer interface { PubKey(context.Context, *empty.Empty) (*PubKeyResponse, error) DataSources(*empty.Empty, OracleService_DataSourcesServer) error RPoint(context.Context, *RPointRequest) (*RPointResponse, error) Publication(context.Context, *PublicationRequest) (*PublicationResponse, error) Publications(*PublicationsRequest, OracleService_PublicationsServer) error }
OracleServiceServer is the server API for OracleService service.
type OracleService_DataSourcesClient ¶
type OracleService_DataSourcesClient interface { Recv() (*DataSourcesResponse, error) grpc.ClientStream }
type OracleService_DataSourcesServer ¶
type OracleService_DataSourcesServer interface { Send(*DataSourcesResponse) error grpc.ServerStream }
type OracleService_PublicationsClient ¶
type OracleService_PublicationsClient interface { Recv() (*PublicationResponse, error) grpc.ClientStream }
type OracleService_PublicationsServer ¶
type OracleService_PublicationsServer interface { Send(*PublicationResponse) error grpc.ServerStream }
type PubKeyResponse ¶
type PubKeyResponse struct { Pubkey string `protobuf:"bytes,1,opt,name=pubkey,proto3" json:"pubkey,omitempty"` // contains filtered or unexported fields }
func (*PubKeyResponse) Descriptor
deprecated
func (*PubKeyResponse) Descriptor() ([]byte, []int)
Deprecated: Use PubKeyResponse.ProtoReflect.Descriptor instead.
func (*PubKeyResponse) GetPubkey ¶
func (x *PubKeyResponse) GetPubkey() string
func (*PubKeyResponse) ProtoMessage ¶
func (*PubKeyResponse) ProtoMessage()
func (*PubKeyResponse) ProtoReflect ¶
func (x *PubKeyResponse) ProtoReflect() protoreflect.Message
func (*PubKeyResponse) Reset ¶
func (x *PubKeyResponse) Reset()
func (*PubKeyResponse) String ¶
func (x *PubKeyResponse) String() string
type PublicationRequest ¶
type PublicationRequest struct { RPoint string `protobuf:"bytes,1,opt,name=r_point,json=rPoint,proto3" json:"r_point,omitempty"` // contains filtered or unexported fields }
func (*PublicationRequest) Descriptor
deprecated
func (*PublicationRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublicationRequest.ProtoReflect.Descriptor instead.
func (*PublicationRequest) GetRPoint ¶
func (x *PublicationRequest) GetRPoint() string
func (*PublicationRequest) ProtoMessage ¶
func (*PublicationRequest) ProtoMessage()
func (*PublicationRequest) ProtoReflect ¶
func (x *PublicationRequest) ProtoReflect() protoreflect.Message
func (*PublicationRequest) Reset ¶
func (x *PublicationRequest) Reset()
func (*PublicationRequest) String ¶
func (x *PublicationRequest) String() string
type PublicationResponse ¶
type PublicationResponse struct { Value uint64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"` Signature string `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` Timestamp uint64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*PublicationResponse) Descriptor
deprecated
func (*PublicationResponse) Descriptor() ([]byte, []int)
Deprecated: Use PublicationResponse.ProtoReflect.Descriptor instead.
func (*PublicationResponse) GetName ¶
func (x *PublicationResponse) GetName() string
func (*PublicationResponse) GetSignature ¶
func (x *PublicationResponse) GetSignature() string
func (*PublicationResponse) GetTimestamp ¶
func (x *PublicationResponse) GetTimestamp() uint64
func (*PublicationResponse) GetValue ¶
func (x *PublicationResponse) GetValue() uint64
func (*PublicationResponse) ProtoMessage ¶
func (*PublicationResponse) ProtoMessage()
func (*PublicationResponse) ProtoReflect ¶
func (x *PublicationResponse) ProtoReflect() protoreflect.Message
func (*PublicationResponse) Reset ¶
func (x *PublicationResponse) Reset()
func (*PublicationResponse) String ¶
func (x *PublicationResponse) String() string
type PublicationsRequest ¶
type PublicationsRequest struct { Base string `protobuf:"bytes,1,opt,name=base,proto3" json:"base,omitempty"` Quote string `protobuf:"bytes,2,opt,name=quote,proto3" json:"quote,omitempty"` // contains filtered or unexported fields }
func (*PublicationsRequest) Descriptor
deprecated
func (*PublicationsRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublicationsRequest.ProtoReflect.Descriptor instead.
func (*PublicationsRequest) GetBase ¶
func (x *PublicationsRequest) GetBase() string
func (*PublicationsRequest) GetQuote ¶
func (x *PublicationsRequest) GetQuote() string
func (*PublicationsRequest) ProtoMessage ¶
func (*PublicationsRequest) ProtoMessage()
func (*PublicationsRequest) ProtoReflect ¶
func (x *PublicationsRequest) ProtoReflect() protoreflect.Message
func (*PublicationsRequest) Reset ¶
func (x *PublicationsRequest) Reset()
func (*PublicationsRequest) String ¶
func (x *PublicationsRequest) String() string
type RPointRequest ¶
type RPointRequest struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*RPointRequest) Descriptor
deprecated
func (*RPointRequest) Descriptor() ([]byte, []int)
Deprecated: Use RPointRequest.ProtoReflect.Descriptor instead.
func (*RPointRequest) GetId ¶
func (x *RPointRequest) GetId() uint64
func (*RPointRequest) GetTimestamp ¶
func (x *RPointRequest) GetTimestamp() int64
func (*RPointRequest) ProtoMessage ¶
func (*RPointRequest) ProtoMessage()
func (*RPointRequest) ProtoReflect ¶
func (x *RPointRequest) ProtoReflect() protoreflect.Message
func (*RPointRequest) Reset ¶
func (x *RPointRequest) Reset()
func (*RPointRequest) String ¶
func (x *RPointRequest) String() string
type RPointResponse ¶
type RPointResponse struct { RPoint string `protobuf:"bytes,1,opt,name=r_point,json=rPoint,proto3" json:"r_point,omitempty"` // contains filtered or unexported fields }
func (*RPointResponse) Descriptor
deprecated
func (*RPointResponse) Descriptor() ([]byte, []int)
Deprecated: Use RPointResponse.ProtoReflect.Descriptor instead.
func (*RPointResponse) GetRPoint ¶
func (x *RPointResponse) GetRPoint() string
func (*RPointResponse) ProtoMessage ¶
func (*RPointResponse) ProtoMessage()
func (*RPointResponse) ProtoReflect ¶
func (x *RPointResponse) ProtoReflect() protoreflect.Message
func (*RPointResponse) Reset ¶
func (x *RPointResponse) Reset()
func (*RPointResponse) String ¶
func (x *RPointResponse) String() string
type UnimplementedOracleServiceServer ¶
type UnimplementedOracleServiceServer struct { }
UnimplementedOracleServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedOracleServiceServer) DataSources ¶
func (*UnimplementedOracleServiceServer) DataSources(*empty.Empty, OracleService_DataSourcesServer) error
func (*UnimplementedOracleServiceServer) PubKey ¶
func (*UnimplementedOracleServiceServer) PubKey(context.Context, *empty.Empty) (*PubKeyResponse, error)
func (*UnimplementedOracleServiceServer) Publication ¶
func (*UnimplementedOracleServiceServer) Publication(context.Context, *PublicationRequest) (*PublicationResponse, error)
func (*UnimplementedOracleServiceServer) Publications ¶
func (*UnimplementedOracleServiceServer) Publications(*PublicationsRequest, OracleService_PublicationsServer) error
func (*UnimplementedOracleServiceServer) RPoint ¶
func (*UnimplementedOracleServiceServer) RPoint(context.Context, *RPointRequest) (*RPointResponse, error)