Documentation
¶
Index ¶
- Variables
- type Blockchain
- type ChainIDValidator
- type Job
- func (*Job) Descriptor() ([]byte, []int)
- func (m *Job) GetId() string
- func (m *Job) GetPipelines() []*Task
- func (*Job) ProtoMessage()
- func (m *Job) Reset()
- func (m *Job) String() string
- func (m *Job) XXX_DiscardUnknown()
- func (m *Job) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Job) XXX_Merge(src proto.Message)
- func (m *Job) XXX_Size() int
- func (m *Job) XXX_Unmarshal(b []byte) error
- type Task
- func (*Task) Descriptor() ([]byte, []int)
- func (m *Task) GetTest() string
- func (*Task) ProtoMessage()
- func (m *Task) Reset()
- func (m *Task) String() string
- func (m *Task) XXX_DiscardUnknown()
- func (m *Task) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Task) XXX_Merge(src proto.Message)
- func (m *Task) XXX_Size() int
- func (m *Task) XXX_Unmarshal(b []byte) error
- type Worker
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrBlockchain = errors.New("invalid blockchain name", errVendor, errors.WithCode(-1)) ErrChainIDs = errors.New("unsupport chainID", errVendor, errors.WithCode(-2)) )
Errors .
View Source
var Blockchain_name = map[int32]string{
0: "BTC",
1: "ETH",
2: "ONT",
3: "BNB",
4: "EOS",
5: "TRX",
}
View Source
var Blockchain_value = map[string]int32{
"BTC": 0,
"ETH": 1,
"ONT": 2,
"BNB": 3,
"EOS": 4,
"TRX": 5,
}
View Source
var Worker_name = map[int32]string{
0: "LUA",
}
View Source
var Worker_value = map[string]int32{
"LUA": 0,
}
Functions ¶
This section is empty.
Types ¶
type Blockchain ¶
type Blockchain int32
const ( Blockchain_BTC Blockchain = 0 Blockchain_ETH Blockchain = 1 Blockchain_ONT Blockchain = 2 Blockchain_BNB Blockchain = 3 Blockchain_EOS Blockchain = 4 Blockchain_TRX Blockchain = 5 )
func (Blockchain) EnumDescriptor ¶
func (Blockchain) EnumDescriptor() ([]byte, []int)
func (Blockchain) MarshalJSON ¶
func (blockchain Blockchain) MarshalJSON() ([]byte, error)
MarshalJSON .
func (Blockchain) String ¶
func (x Blockchain) String() string
func (*Blockchain) UnmarshalJSON ¶
func (blockchain *Blockchain) UnmarshalJSON(b []byte) error
UnmarshalJSON .
type ChainIDValidator ¶
type ChainIDValidator map[Blockchain][]string
ChainIDValidator .
func GetChainIDValidator ¶
func GetChainIDValidator(config scf4go.Config) (ChainIDValidator, error)
GetChainIDValidator .
func (ChainIDValidator) CheckChainID ¶
func (validator ChainIDValidator) CheckChainID(blockchain Blockchain, chainID string) bool
CheckChainID .
type Job ¶
type Job struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Pipelines []*Task `protobuf:"bytes,2,rep,name=pipelines,proto3" json:"pipelines,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Job) Descriptor ¶
func (*Job) GetPipelines ¶
func (*Job) ProtoMessage ¶
func (*Job) ProtoMessage()
func (*Job) XXX_DiscardUnknown ¶
func (m *Job) XXX_DiscardUnknown()
func (*Job) XXX_Unmarshal ¶
type Task ¶
type Task struct { Test string `protobuf:"bytes,1,opt,name=test,proto3" json:"test,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Task) Descriptor ¶
func (*Task) ProtoMessage ¶
func (*Task) ProtoMessage()
func (*Task) XXX_DiscardUnknown ¶
func (m *Task) XXX_DiscardUnknown()
func (*Task) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.