protonode

package
v0.0.0-...-698e449 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2023 License: MIT Imports: 8 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "OK",
		1: "NOT_OK",
	}
	Status_value = map[string]int32{
		"OK":     0,
		"NOT_OK": 1,
	}
)

Enum value maps for Status.

View Source 
var (
	JobTypes_name = map[int32]string{
		0: "DATA_FEED",
		1: "RANDOM_NUMBER",
	}
	JobTypes_value = map[string]int32{
		"DATA_FEED":     0,
		"RANDOM_NUMBER": 1,
	}
)

Enum value maps for JobTypes.

View Source 
var (
	RequestType_name = map[int32]string{
		0: "GET",
		1: "POST",
	}
	RequestType_value = map[string]int32{
		"GET":  0,
		"POST": 1,
	}
)

Enum value maps for RequestType.

View Source 
var (
	FeedCategory_name = map[int32]string{
		0: "RNG",
		1: "SPORT",
		2: "PRICE_FEED",
		3: "WEATHER",
		4: "FLIGHT",
		5: "BLOCKCHAIN",
		6: "NFT_DATA",
	}
	FeedCategory_value = map[string]int32{
		"RNG":        0,
		"SPORT":      1,
		"PRICE_FEED": 2,
		"WEATHER":    3,
		"FLIGHT":     4,
		"BLOCKCHAIN": 5,
		"NFT_DATA":   6,
	}
)

Enum value maps for FeedCategory.

View Source 
var File_node_protonode_node_proto protoreflect.FileDescriptor
View Source 
var NodeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "protonode.NodeService",
	HandlerType: (*NodeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "HandShake",
			Handler:    _NodeService_HandShake_Handler,
		},
		{
			MethodName: "QueueJob",
			Handler:    _NodeService_QueueJob_Handler,
		},
		{
			MethodName: "AddToKnownPeers",
			Handler:    _NodeService_AddToKnownPeers_Handler,
		},
		{
			MethodName: "ListKnownPeers",
			Handler:    _NodeService_ListKnownPeers_Handler,
		},
		{
			MethodName: "NodeJobsCount",
			Handler:    _NodeService_NodeJobsCount_Handler,
		},
		{
			MethodName: "TotalNetworkRequests",
			Handler:    _NodeService_TotalNetworkRequests_Handler,
		},
		{
			MethodName: "FeedHistory",
			Handler:    _NodeService_FeedHistory_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "node/protonode/node.proto",
}

NodeService_ServiceDesc is the grpc.ServiceDesc for NodeService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterNodeServiceServer 

func RegisterNodeServiceServer(s grpc.ServiceRegistrar, srv NodeServiceServer)

Types

type Adapter 

type Adapter struct {
	Active        bool         `protobuf:"varint,1,opt,name=active,proto3" json:"active,omitempty"`
	Name          string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	JobType       JobTypes     `protobuf:"varint,3,opt,name=job_type,json=jobType,proto3,enum=protonode.JobTypes" json:"job_type,omitempty"`
	AdapterId     string       `protobuf:"bytes,4,opt,name=adapter_id,json=adapterId,proto3" json:"adapter_id,omitempty"`
	OracleAddress string       `protobuf:"bytes,5,opt,name=oracle_address,json=oracleAddress,proto3" json:"oracle_address,omitempty"`
	Feeds         []*Feed      `protobuf:"bytes,6,rep,name=feeds,proto3" json:"feeds,omitempty"`
	Category      FeedCategory `protobuf:"varint,7,opt,name=category,proto3,enum=protonode.FeedCategory" json:"category,omitempty"`
	Frequency     int64        `protobuf:"varint,8,opt,name=frequency,proto3" json:"frequency,omitempty"`
	// contains filtered or unexported fields
}

func (*Adapter) Descriptor deprecated 

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

Deprecated: Use Adapter.ProtoReflect.Descriptor instead.

func (*Adapter) GetActive 

func (x *Adapter) GetActive() bool

func (*Adapter) GetAdapterId 

func (x *Adapter) GetAdapterId() string

func (*Adapter) GetCategory 

func (x *Adapter) GetCategory() FeedCategory

func (*Adapter) GetFeeds 

func (x *Adapter) GetFeeds() []*Feed

func (*Adapter) GetFrequency 

func (x *Adapter) GetFrequency() int64

func (*Adapter) GetJobType 

func (x *Adapter) GetJobType() JobTypes

func (*Adapter) GetName 

func (x *Adapter) GetName() string

func (*Adapter) GetOracleAddress 

func (x *Adapter) GetOracleAddress() string

func (*Adapter) ProtoMessage 

func (*Adapter) ProtoMessage()

func (*Adapter) ProtoReflect 

func (x *Adapter) ProtoReflect() protoreflect.Message

func (*Adapter) Reset 

func (x *Adapter) Reset()

func (*Adapter) String 

func (x *Adapter) String() string

type Adapters 

type Adapters struct {
	Adapters []*Adapter `protobuf:"bytes,1,rep,name=adapters,proto3" json:"adapters,omitempty"`
	// contains filtered or unexported fields
}

func (*Adapters) Descriptor deprecated 

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

Deprecated: Use Adapters.ProtoReflect.Descriptor instead.

func (*Adapters) GetAdapters 

func (x *Adapters) GetAdapters() []*Adapter

func (*Adapters) ProtoMessage 

func (*Adapters) ProtoMessage()

func (*Adapters) ProtoReflect 

func (x *Adapters) ProtoReflect() protoreflect.Message

func (*Adapters) Reset 

func (x *Adapters) Reset()

func (*Adapters) String 

func (x *Adapters) String() string

type DPInfo 

type DPInfo struct {
	ListenAddress string             `protobuf:"bytes,1,opt,name=listen_address,json=listenAddress,proto3" json:"listen_address,omitempty"`
	Name          string             `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	KOrgId        string             `protobuf:"bytes,3,opt,name=k_org_id,json=kOrgId,proto3" json:"k_org_id,omitempty"`
	KnownPeers    map[string]*DPInfo `` /* 161-byte string literal not displayed */
	Bootstraps    map[string]*DPInfo `` /* 161-byte string literal not displayed */
	Website       string             `protobuf:"bytes,6,opt,name=website,proto3" json:"website,omitempty"`
	// contains filtered or unexported fields
}

func (*DPInfo) Descriptor deprecated 

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

Deprecated: Use DPInfo.ProtoReflect.Descriptor instead.

func (*DPInfo) GetBootstraps 

func (x *DPInfo) GetBootstraps() map[string]*DPInfo

func (*DPInfo) GetKOrgId 

func (x *DPInfo) GetKOrgId() string

func (*DPInfo) GetKnownPeers 

func (x *DPInfo) GetKnownPeers() map[string]*DPInfo

func (*DPInfo) GetListenAddress 

func (x *DPInfo) GetListenAddress() string

func (*DPInfo) GetName 

func (x *DPInfo) GetName() string

func (*DPInfo) GetWebsite 

func (x *DPInfo) GetWebsite() string

func (*DPInfo) ProtoMessage 

func (*DPInfo) ProtoMessage()

func (*DPInfo) ProtoReflect 

func (x *DPInfo) ProtoReflect() protoreflect.Message

func (*DPInfo) Reset 

func (x *DPInfo) Reset()

func (*DPInfo) String 

func (x *DPInfo) String() string

type DPInfos 

type DPInfos struct {
	List []*DPInfo `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*DPInfos) Descriptor deprecated 

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

Deprecated: Use DPInfos.ProtoReflect.Descriptor instead.

func (*DPInfos) GetList 

func (x *DPInfos) GetList() []*DPInfo

func (*DPInfos) ProtoMessage 

func (*DPInfos) ProtoMessage()

func (*DPInfos) ProtoReflect 

func (x *DPInfos) ProtoReflect() protoreflect.Message

func (*DPInfos) Reset 

func (x *DPInfos) Reset()

func (*DPInfos) String 

func (x *DPInfos) String() string

type Feed 

type Feed struct {
	Url         string         `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Headers     []*Feed_Header `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	RequestType RequestType    `protobuf:"varint,3,opt,name=request_type,json=requestType,proto3,enum=protonode.RequestType" json:"request_type,omitempty"`
	Reducers    []*Reducer     `protobuf:"bytes,4,rep,name=reducers,proto3" json:"reducers,omitempty"`
	Payload     string         `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*Feed) Descriptor deprecated 

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

Deprecated: Use Feed.ProtoReflect.Descriptor instead.

func (*Feed) GetHeaders 

func (x *Feed) GetHeaders() []*Feed_Header

func (*Feed) GetPayload 

func (x *Feed) GetPayload() string

func (*Feed) GetReducers 

func (x *Feed) GetReducers() []*Reducer

func (*Feed) GetRequestType 

func (x *Feed) GetRequestType() RequestType

func (*Feed) GetUrl 

func (x *Feed) GetUrl() string

func (*Feed) ProtoMessage 

func (*Feed) ProtoMessage()

func (*Feed) ProtoReflect 

func (x *Feed) ProtoReflect() protoreflect.Message

func (*Feed) Reset 

func (x *Feed) Reset()

func (*Feed) String 

func (x *Feed) String() string

type FeedCategory 

type FeedCategory int32
const (
	FeedCategory_RNG        FeedCategory = 0 // random number generator
	FeedCategory_SPORT      FeedCategory = 1 // live scores, past data e.t.c
	FeedCategory_PRICE_FEED FeedCategory = 2 // data such as spot prices
	FeedCategory_WEATHER    FeedCategory = 3 // transactions or balances happening on other blockchains
	FeedCategory_FLIGHT     FeedCategory = 4 // departure and arrival statuses on-chain
	FeedCategory_BLOCKCHAIN FeedCategory = 5 // transactions or balances happening on other blockchains
	FeedCategory_NFT_DATA   FeedCategory = 6 // floor Prices, Asset Listings, Collection Details
)

func (FeedCategory) Descriptor 

func (FeedCategory) Descriptor() protoreflect.EnumDescriptor

func (FeedCategory) Enum 

func (x FeedCategory) Enum() *FeedCategory

func (FeedCategory) EnumDescriptor deprecated 

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

Deprecated: Use FeedCategory.Descriptor instead.

func (FeedCategory) Number 

func (x FeedCategory) Number() protoreflect.EnumNumber

func (FeedCategory) String 

func (x FeedCategory) String() string

func (FeedCategory) Type 

func (FeedCategory) Type() protoreflect.EnumType

type FeedHistories 

type FeedHistories struct {
	Feed []*FeedHistory `protobuf:"bytes,1,rep,name=feed,proto3" json:"feed,omitempty"`
	// contains filtered or unexported fields
}

func (*FeedHistories) Descriptor deprecated 

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

Deprecated: Use FeedHistories.ProtoReflect.Descriptor instead.

func (*FeedHistories) GetFeed 

func (x *FeedHistories) GetFeed() []*FeedHistory

func (*FeedHistories) ProtoMessage 

func (*FeedHistories) ProtoMessage()

func (*FeedHistories) ProtoReflect 

func (x *FeedHistories) ProtoReflect() protoreflect.Message

func (*FeedHistories) Reset 

func (x *FeedHistories) Reset()

func (*FeedHistories) String 

func (x *FeedHistories) String() string

type FeedHistory 

type FeedHistory struct {
	RoundAnswer uint64  `protobuf:"varint,1,opt,name=round_answer,json=roundAnswer,proto3" json:"round_answer,omitempty"`
	Period      uint64  `protobuf:"varint,2,opt,name=period,proto3" json:"period,omitempty"`
	AdapterId   string  `protobuf:"bytes,3,opt,name=adapter_id,json=adapterId,proto3" json:"adapter_id,omitempty"`
	Responses   []int64 `protobuf:"varint,4,rep,packed,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*FeedHistory) Descriptor deprecated 

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

Deprecated: Use FeedHistory.ProtoReflect.Descriptor instead.

func (*FeedHistory) GetAdapterId 

func (x *FeedHistory) GetAdapterId() string

func (*FeedHistory) GetPeriod 

func (x *FeedHistory) GetPeriod() uint64

func (*FeedHistory) GetResponses 

func (x *FeedHistory) GetResponses() []int64

func (*FeedHistory) GetRoundAnswer 

func (x *FeedHistory) GetRoundAnswer() uint64

func (*FeedHistory) ProtoMessage 

func (*FeedHistory) ProtoMessage()

func (*FeedHistory) ProtoReflect 

func (x *FeedHistory) ProtoReflect() protoreflect.Message

func (*FeedHistory) Reset 

func (x *FeedHistory) Reset()

func (*FeedHistory) String 

func (x *FeedHistory) String() string

type FeedHistoryRequest 

type FeedHistoryRequest struct {
	FromTimestamp uint64 `protobuf:"varint,1,opt,name=from_timestamp,json=fromTimestamp,proto3" json:"from_timestamp,omitempty"`
	ToTimestamp   uint64 `protobuf:"varint,2,opt,name=to_timestamp,json=toTimestamp,proto3" json:"to_timestamp,omitempty"`
	AdapterId     string `protobuf:"bytes,3,opt,name=adapter_id,json=adapterId,proto3" json:"adapter_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FeedHistoryRequest) Descriptor deprecated 

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

Deprecated: Use FeedHistoryRequest.ProtoReflect.Descriptor instead.

func (*FeedHistoryRequest) GetAdapterId 

func (x *FeedHistoryRequest) GetAdapterId() string

func (*FeedHistoryRequest) GetFromTimestamp 

func (x *FeedHistoryRequest) GetFromTimestamp() uint64

func (*FeedHistoryRequest) GetToTimestamp 

func (x *FeedHistoryRequest) GetToTimestamp() uint64

func (*FeedHistoryRequest) ProtoMessage 

func (*FeedHistoryRequest) ProtoMessage()

func (*FeedHistoryRequest) ProtoReflect 

func (x *FeedHistoryRequest) ProtoReflect() protoreflect.Message

func (*FeedHistoryRequest) Reset 

func (x *FeedHistoryRequest) Reset()

func (*FeedHistoryRequest) String 

func (x *FeedHistoryRequest) String() string

type Feed_Header 

type Feed_Header struct {
	Field map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Feed_Header) Descriptor deprecated 

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

Deprecated: Use Feed_Header.ProtoReflect.Descriptor instead.

func (*Feed_Header) GetField 

func (x *Feed_Header) GetField() map[string]string

func (*Feed_Header) ProtoMessage 

func (*Feed_Header) ProtoMessage()

func (*Feed_Header) ProtoReflect 

func (x *Feed_Header) ProtoReflect() protoreflect.Message

func (*Feed_Header) Reset 

func (x *Feed_Header) Reset()

func (*Feed_Header) String 

func (x *Feed_Header) String() string

type HandShakeStatus 

type HandShakeStatus struct {
	Status   bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	ErrorMsg string `protobuf:"bytes,2,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	// contains filtered or unexported fields
}

func (*HandShakeStatus) Descriptor deprecated 

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

Deprecated: Use HandShakeStatus.ProtoReflect.Descriptor instead.

func (*HandShakeStatus) GetErrorMsg 

func (x *HandShakeStatus) GetErrorMsg() string

func (*HandShakeStatus) GetStatus 

func (x *HandShakeStatus) GetStatus() bool

func (*HandShakeStatus) ProtoMessage 

func (*HandShakeStatus) ProtoMessage()

func (*HandShakeStatus) ProtoReflect 

func (x *HandShakeStatus) ProtoReflect() protoreflect.Message

func (*HandShakeStatus) Reset 

func (x *HandShakeStatus) Reset()

func (*HandShakeStatus) String 

func (x *HandShakeStatus) String() string

type JobLength 

type JobLength struct {
	Value int64 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*JobLength) Descriptor deprecated 

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

Deprecated: Use JobLength.ProtoReflect.Descriptor instead.

func (*JobLength) GetValue 

func (x *JobLength) GetValue() int64

func (*JobLength) ProtoMessage 

func (*JobLength) ProtoMessage()

func (*JobLength) ProtoReflect 

func (x *JobLength) ProtoReflect() protoreflect.Message

func (*JobLength) Reset 

func (x *JobLength) Reset()

func (*JobLength) String 

func (x *JobLength) String() string

type JobTypes 

type JobTypes int32
const (
	JobTypes_DATA_FEED     JobTypes = 0
	JobTypes_RANDOM_NUMBER JobTypes = 1
)

func (JobTypes) Descriptor 

func (JobTypes) Descriptor() protoreflect.EnumDescriptor

func (JobTypes) Enum 

func (x JobTypes) Enum() *JobTypes

func (JobTypes) EnumDescriptor deprecated 

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

Deprecated: Use JobTypes.Descriptor instead.

func (JobTypes) Number 

func (x JobTypes) Number() protoreflect.EnumNumber

func (JobTypes) String 

func (x JobTypes) String() string

func (JobTypes) Type 

func (JobTypes) Type() protoreflect.EnumType

type NetworkStat 

type NetworkStat struct {
	Nodes           uint64 `protobuf:"varint,1,opt,name=nodes,proto3" json:"nodes,omitempty"`
	DataProviders   uint64 `protobuf:"varint,2,opt,name=data_providers,json=dataProviders,proto3" json:"data_providers,omitempty"`
	Feeds           uint64 `protobuf:"varint,3,opt,name=feeds,proto3" json:"feeds,omitempty"`
	NetworkRequests uint64 `protobuf:"varint,4,opt,name=network_requests,json=networkRequests,proto3" json:"network_requests,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkStat) Descriptor deprecated 

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

Deprecated: Use NetworkStat.ProtoReflect.Descriptor instead.

func (*NetworkStat) GetDataProviders 

func (x *NetworkStat) GetDataProviders() uint64

func (*NetworkStat) GetFeeds 

func (x *NetworkStat) GetFeeds() uint64

func (*NetworkStat) GetNetworkRequests 

func (x *NetworkStat) GetNetworkRequests() uint64

func (*NetworkStat) GetNodes 

func (x *NetworkStat) GetNodes() uint64

func (*NetworkStat) ProtoMessage 

func (*NetworkStat) ProtoMessage()

func (*NetworkStat) ProtoReflect 

func (x *NetworkStat) ProtoReflect() protoreflect.Message

func (*NetworkStat) Reset 

func (x *NetworkStat) Reset()

func (*NetworkStat) String 

func (x *NetworkStat) String() string

type NodeInfo 

type NodeInfo struct {
	ListenAddress string               `protobuf:"bytes,1,opt,name=listen_address,json=listenAddress,proto3" json:"listen_address,omitempty"`
	Name          string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	KOrgId        string               `protobuf:"bytes,3,opt,name=k_org_id,json=kOrgId,proto3" json:"k_org_id,omitempty"`
	KnownPeers    map[string]*NodeInfo `` /* 161-byte string literal not displayed */
	Bootstraps    map[string]*NodeInfo `` /* 161-byte string literal not displayed */
	Website       string               `protobuf:"bytes,6,opt,name=website,proto3" json:"website,omitempty"`
	Uptime        int64                `protobuf:"varint,7,opt,name=uptime,proto3" json:"uptime,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetBootstraps 

func (x *NodeInfo) GetBootstraps() map[string]*NodeInfo

func (*NodeInfo) GetKOrgId 

func (x *NodeInfo) GetKOrgId() string

func (*NodeInfo) GetKnownPeers 

func (x *NodeInfo) GetKnownPeers() map[string]*NodeInfo

func (*NodeInfo) GetListenAddress 

func (x *NodeInfo) GetListenAddress() string

func (*NodeInfo) GetName 

func (x *NodeInfo) GetName() string

func (*NodeInfo) GetUptime 

func (x *NodeInfo) GetUptime() int64

func (*NodeInfo) GetWebsite 

func (x *NodeInfo) GetWebsite() string

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

func (x *NodeInfo) ProtoReflect() protoreflect.Message

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type NodeInfos 

type NodeInfos struct {
	List []*NodeInfo `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfos) Descriptor deprecated 

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

Deprecated: Use NodeInfos.ProtoReflect.Descriptor instead.

func (*NodeInfos) GetList 

func (x *NodeInfos) GetList() []*NodeInfo

func (*NodeInfos) ProtoMessage 

func (*NodeInfos) ProtoMessage()

func (*NodeInfos) ProtoReflect 

func (x *NodeInfos) ProtoReflect() protoreflect.Message

func (*NodeInfos) Reset 

func (x *NodeInfos) Reset()

func (*NodeInfos) String 

func (x *NodeInfos) String() string

type NodeServiceClient 

type NodeServiceClient interface {
	HandShake(ctx context.Context, in *DPInfo, opts ...grpc.CallOption) (*HandShakeStatus, error)
	QueueJob(ctx context.Context, in *Adapter, opts ...grpc.CallOption) (*RequestStatus, error)
	AddToKnownPeers(ctx context.Context, in *NodeInfo, opts ...grpc.CallOption) (*Null, error)
	ListKnownPeers(ctx context.Context, in *Null, opts ...grpc.CallOption) (*NodeInfos, error)
	NodeJobsCount(ctx context.Context, in *Null, opts ...grpc.CallOption) (*JobLength, error)
	TotalNetworkRequests(ctx context.Context, in *Null, opts ...grpc.CallOption) (*JobLength, error)
	FeedHistory(ctx context.Context, in *FeedHistoryRequest, opts ...grpc.CallOption) (*FeedHistories, error)
}

NodeServiceClient is the client API for NodeService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewNodeServiceClient 

func NewNodeServiceClient(cc grpc.ClientConnInterface) NodeServiceClient

type NodeServiceServer 

type NodeServiceServer interface {
	HandShake(context.Context, *DPInfo) (*HandShakeStatus, error)
	QueueJob(context.Context, *Adapter) (*RequestStatus, error)
	AddToKnownPeers(context.Context, *NodeInfo) (*Null, error)
	ListKnownPeers(context.Context, *Null) (*NodeInfos, error)
	NodeJobsCount(context.Context, *Null) (*JobLength, error)
	TotalNetworkRequests(context.Context, *Null) (*JobLength, error)
	FeedHistory(context.Context, *FeedHistoryRequest) (*FeedHistories, error)
	// contains filtered or unexported methods
}

NodeServiceServer is the server API for NodeService service. All implementations must embed UnimplementedNodeServiceServer for forward compatibility

type Null 

type Null struct {
	// contains filtered or unexported fields
}

func (*Null) Descriptor deprecated 

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

Deprecated: Use Null.ProtoReflect.Descriptor instead.

func (*Null) ProtoMessage 

func (*Null) ProtoMessage()

func (*Null) ProtoReflect 

func (x *Null) ProtoReflect() protoreflect.Message

func (*Null) Reset 

func (x *Null) Reset()

func (*Null) String 

func (x *Null) String() string

type OracleRequest 

type OracleRequest struct {
	RequestId          []byte `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	NodeAddress        []byte `protobuf:"bytes,2,opt,name=nodeAddress,proto3" json:"nodeAddress,omitempty"`
	AdapterId          []byte `protobuf:"bytes,3,opt,name=adapter_id,json=adapterId,proto3" json:"adapter_id,omitempty"`
	CallbackFunctionId []byte `protobuf:"bytes,4,opt,name=callback_function_id,json=callbackFunctionId,proto3" json:"callback_function_id,omitempty"`
	CallbackContract   []byte `protobuf:"bytes,5,opt,name=callback_contract,json=callbackContract,proto3" json:"callback_contract,omitempty"`
	Data               []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	Timestamp          []byte `protobuf:"bytes,7,opt,name=timestamp,proto3" json:"timestamp,omitempty"` //Gets it as uint256, but since proto types only support uint64, we do this to avoid truncation
	// contains filtered or unexported fields
}

func (*OracleRequest) Descriptor deprecated 

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

Deprecated: Use OracleRequest.ProtoReflect.Descriptor instead.

func (*OracleRequest) GetAdapterId 

func (x *OracleRequest) GetAdapterId() []byte

func (*OracleRequest) GetCallbackContract 

func (x *OracleRequest) GetCallbackContract() []byte

func (*OracleRequest) GetCallbackFunctionId 

func (x *OracleRequest) GetCallbackFunctionId() []byte

func (*OracleRequest) GetData 

func (x *OracleRequest) GetData() []byte

func (*OracleRequest) GetNodeAddress 

func (x *OracleRequest) GetNodeAddress() []byte

func (*OracleRequest) GetRequestId 

func (x *OracleRequest) GetRequestId() []byte

func (*OracleRequest) GetTimestamp 

func (x *OracleRequest) GetTimestamp() []byte

func (*OracleRequest) ProtoMessage 

func (*OracleRequest) ProtoMessage()

func (*OracleRequest) ProtoReflect 

func (x *OracleRequest) ProtoReflect() protoreflect.Message

func (*OracleRequest) Reset 

func (x *OracleRequest) Reset()

func (*OracleRequest) String 

func (x *OracleRequest) String() string

type Reducer 

type Reducer struct {
	Function string   `protobuf:"bytes,1,opt,name=function,proto3" json:"function,omitempty"`
	Args     []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*Reducer) Descriptor deprecated 

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

Deprecated: Use Reducer.ProtoReflect.Descriptor instead.

func (*Reducer) GetArgs 

func (x *Reducer) GetArgs() []string

func (*Reducer) GetFunction 

func (x *Reducer) GetFunction() string

func (*Reducer) ProtoMessage 

func (*Reducer) ProtoMessage()

func (*Reducer) ProtoReflect 

func (x *Reducer) ProtoReflect() protoreflect.Message

func (*Reducer) Reset 

func (x *Reducer) Reset()

func (*Reducer) String 

func (x *Reducer) String() string

type RequestStatus 

type RequestStatus struct {
	Status uint64 `protobuf:"varint,1,opt,name=Status,proto3" json:"Status,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestStatus) Descriptor deprecated 

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

Deprecated: Use RequestStatus.ProtoReflect.Descriptor instead.

func (*RequestStatus) GetStatus 

func (x *RequestStatus) GetStatus() uint64

func (*RequestStatus) ProtoMessage 

func (*RequestStatus) ProtoMessage()

func (*RequestStatus) ProtoReflect 

func (x *RequestStatus) ProtoReflect() protoreflect.Message

func (*RequestStatus) Reset 

func (x *RequestStatus) Reset()

func (*RequestStatus) String 

func (x *RequestStatus) String() string

type RequestType 

type RequestType int32
const (
	RequestType_GET  RequestType = 0
	RequestType_POST RequestType = 1
)

func (RequestType) Descriptor 

func (RequestType) Descriptor() protoreflect.EnumDescriptor

func (RequestType) Enum 

func (x RequestType) Enum() *RequestType

func (RequestType) EnumDescriptor deprecated 

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

Deprecated: Use RequestType.Descriptor instead.

func (RequestType) Number 

func (x RequestType) Number() protoreflect.EnumNumber

func (RequestType) String 

func (x RequestType) String() string

func (RequestType) Type 

func (RequestType) Type() protoreflect.EnumType

type Status 

type Status int32
const (
	Status_OK     Status = 0
	Status_NOT_OK Status = 1
)

func (Status) Descriptor 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated 

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

Deprecated: Use Status.Descriptor instead.

func (Status) Number 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String 

func (x Status) String() string

func (Status) Type 

func (Status) Type() protoreflect.EnumType

type UnimplementedNodeServiceServer 

type UnimplementedNodeServiceServer struct {
}

UnimplementedNodeServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedNodeServiceServer) AddToKnownPeers 

func (UnimplementedNodeServiceServer) AddToKnownPeers(context.Context, *NodeInfo) (*Null, error)

func (UnimplementedNodeServiceServer) FeedHistory 

func (UnimplementedNodeServiceServer) FeedHistory(context.Context, *FeedHistoryRequest) (*FeedHistories, error)

func (UnimplementedNodeServiceServer) HandShake 

func (UnimplementedNodeServiceServer) HandShake(context.Context, *DPInfo) (*HandShakeStatus, error)

func (UnimplementedNodeServiceServer) ListKnownPeers 

func (UnimplementedNodeServiceServer) ListKnownPeers(context.Context, *Null) (*NodeInfos, error)

func (UnimplementedNodeServiceServer) NodeJobsCount 

func (UnimplementedNodeServiceServer) NodeJobsCount(context.Context, *Null) (*JobLength, error)

func (UnimplementedNodeServiceServer) QueueJob 

func (UnimplementedNodeServiceServer) QueueJob(context.Context, *Adapter) (*RequestStatus, error)

func (UnimplementedNodeServiceServer) TotalNetworkRequests 

func (UnimplementedNodeServiceServer) TotalNetworkRequests(context.Context, *Null) (*JobLength, error)

type UnsafeNodeServiceServer 

type UnsafeNodeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeNodeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to NodeServiceServer will result in compilation errors.

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.