types

package
v6.1.0+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2019 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ActionEventPublish = iota + 1 //事件发布
	ActionResultPrePublish
	ActionResultPublish
	ActionEventAbort
	ActionResultAbort
)

oracle action type

View Source 
const (
	NoEvent = iota
	EventPublished
	EventAborted
	ResultPrePublished
	ResultAborted
	ResultPublished
)

oracle status

View Source 
const (
	TyLogEventPublish     = 810
	TyLogEventAbort       = 811
	TyLogResultPrePublish = 812
	TyLogResultAbort      = 813
	TyLogResultPublish    = 814
)

log type define

View Source 
const (
	// FuncNameQueryOracleListByIDs 根据ids查询OracleStatus
	FuncNameQueryOracleListByIDs = "QueryOraclesByIDs"
	// FuncNameQueryEventIDByStatus 根据状态查询eventID
	FuncNameQueryEventIDByStatus = "QueryEventIDsByStatus"
	// FuncNameQueryEventIDByAddrAndStatus 根据创建者地址和状态查询eventID
	FuncNameQueryEventIDByAddrAndStatus = "QueryEventIDsByAddrAndStatus"
	// FuncNameQueryEventIDByTypeAndStatus 根据事件类型和状态查询eventID
	FuncNameQueryEventIDByTypeAndStatus = "QueryEventIDsByTypeAndStatus"
	// CreateEventPublishTx 创建发布事件交易
	CreateEventPublishTx = "EventPublish"
	// CreateAbortEventPublishTx 创建取消发布事件交易
	CreateAbortEventPublishTx = "EventAbort"
	// CreatePrePublishResultTx 创建预发布事件结果交易
	CreatePrePublishResultTx = "ResultPrePublish"
	// CreateAbortResultPrePublishTx 创建取消预发布的事件结果交易
	CreateAbortResultPrePublishTx = "ResultAbort"
	// CreateResultPublishTx 创建预发布事件结果交易
	CreateResultPublishTx = "ResultPublish"
)

executor action and function define

View Source 
const (
	// ListDESC 降序
	ListDESC = int32(0)
	// DefaultCount 默认一次取多少条记录
	DefaultCount = int32(20)
)

query param define

Variables

View Source 
var (
	ErrTimeMustBeFuture           = errors.New("ErrTimeMustBeFuture")
	ErrNoPrivilege                = errors.New("ErrNoPrivilege")
	ErrOracleRepeatHash           = errors.New("ErrOracleRepeatHash")
	ErrEventIDNotFound            = errors.New("ErrEventIDNotFound")
	ErrEventAbortNotAllowed       = errors.New("ErrEventAbortNotAllowed")
	ErrResultPrePublishNotAllowed = errors.New("ErrResultPrePublishNotAllowed")
	ErrPrePublishAbortNotAllowed  = errors.New("ErrPrePublishAbortNotAllowed")
	ErrResultPublishNotAllowed    = errors.New("ErrResultPublishNotAllowed")
	ErrParamNeedIDs               = errors.New("ErrParamNeedIDs")
	ErrParamStatusInvalid         = errors.New("ErrParamStatusInvalid")
	ErrParamAddressMustnotEmpty   = errors.New("ErrParamAddressMustnotEmpty")
	ErrParamTypeMustNotEmpty      = errors.New("ErrParamTypeMustNotEmpty")
)

Errors for oracle

View Source 
var (
	// OracleX oracle name
	OracleX = "oracle"
)

Functions

func NewTable 

func NewTable(kvdb db.KV) *table.Table

NewTable 新建表

Types

type EventAbort 

type EventAbort struct {
	EventID              string   `protobuf:"bytes,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventAbort) Descriptor 

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

func (*EventAbort) GetEventID 

func (m *EventAbort) GetEventID() string

func (*EventAbort) ProtoMessage 

func (*EventAbort) ProtoMessage()

func (*EventAbort) Reset 

func (m *EventAbort) Reset()

func (*EventAbort) String 

func (m *EventAbort) String() string

func (*EventAbort) XXX_DiscardUnknown 

func (m *EventAbort) XXX_DiscardUnknown()

func (*EventAbort) XXX_Marshal 

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

func (*EventAbort) XXX_Merge 

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

func (*EventAbort) XXX_Size 

func (m *EventAbort) XXX_Size() int

func (*EventAbort) XXX_Unmarshal 

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

type EventPublish 

type EventPublish struct {
	Type                 string   `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	SubType              string   `protobuf:"bytes,3,opt,name=subType,proto3" json:"subType,omitempty"`
	Time                 int64    `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
	Content              string   `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Introduction         string   `protobuf:"bytes,6,opt,name=introduction,proto3" json:"introduction,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventPublish) Descriptor 

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

func (*EventPublish) GetContent 

func (m *EventPublish) GetContent() string

func (*EventPublish) GetIntroduction 

func (m *EventPublish) GetIntroduction() string

func (*EventPublish) GetSubType 

func (m *EventPublish) GetSubType() string

func (*EventPublish) GetTime 

func (m *EventPublish) GetTime() int64

func (*EventPublish) GetType 

func (m *EventPublish) GetType() string

func (*EventPublish) ProtoMessage 

func (*EventPublish) ProtoMessage()

func (*EventPublish) Reset 

func (m *EventPublish) Reset()

func (*EventPublish) String 

func (m *EventPublish) String() string

func (*EventPublish) XXX_DiscardUnknown 

func (m *EventPublish) XXX_DiscardUnknown()

func (*EventPublish) XXX_Marshal 

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

func (*EventPublish) XXX_Merge 

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

func (*EventPublish) XXX_Size 

func (m *EventPublish) XXX_Size() int

func (*EventPublish) XXX_Unmarshal 

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

type EventRecord 

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

localDB

func (*EventRecord) Descriptor 

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

func (*EventRecord) GetEventID 

func (m *EventRecord) GetEventID() string

func (*EventRecord) ProtoMessage 

func (*EventRecord) ProtoMessage()

func (*EventRecord) Reset 

func (m *EventRecord) Reset()

func (*EventRecord) String 

func (m *EventRecord) String() string

func (*EventRecord) XXX_DiscardUnknown 

func (m *EventRecord) XXX_DiscardUnknown()

func (*EventRecord) XXX_Marshal 

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

func (*EventRecord) XXX_Merge 

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

func (*EventRecord) XXX_Size 

func (m *EventRecord) XXX_Size() int

func (*EventRecord) XXX_Unmarshal 

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

type EventStatus 

type EventStatus struct {
	OpAddr               string   `protobuf:"bytes,1,opt,name=opAddr,proto3" json:"opAddr,omitempty"`
	Status               int32    `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EventStatus) Descriptor 

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

func (*EventStatus) GetOpAddr 

func (m *EventStatus) GetOpAddr() string

func (*EventStatus) GetStatus 

func (m *EventStatus) GetStatus() int32

func (*EventStatus) ProtoMessage 

func (*EventStatus) ProtoMessage()

func (*EventStatus) Reset 

func (m *EventStatus) Reset()

func (*EventStatus) String 

func (m *EventStatus) String() string

func (*EventStatus) XXX_DiscardUnknown 

func (m *EventStatus) XXX_DiscardUnknown()

func (*EventStatus) XXX_Marshal 

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

func (*EventStatus) XXX_Merge 

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

func (*EventStatus) XXX_Size 

func (m *EventStatus) XXX_Size() int

func (*EventStatus) XXX_Unmarshal 

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

type OracleAction 

type OracleAction struct {
	// Types that are valid to be assigned to Value:
	//	*OracleAction_EventPublish
	//	*OracleAction_EventAbort
	//	*OracleAction_ResultPrePublish
	//	*OracleAction_ResultPublish
	//	*OracleAction_ResultAbort
	Value                isOracleAction_Value `protobuf_oneof:"value"`
	Ty                   int32                `protobuf:"varint,7,opt,name=Ty,proto3" json:"Ty,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

action

func (*OracleAction) Descriptor 

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

func (*OracleAction) GetEventAbort 

func (m *OracleAction) GetEventAbort() *EventAbort

func (*OracleAction) GetEventPublish 

func (m *OracleAction) GetEventPublish() *EventPublish

func (*OracleAction) GetResultAbort 

func (m *OracleAction) GetResultAbort() *ResultAbort

func (*OracleAction) GetResultPrePublish 

func (m *OracleAction) GetResultPrePublish() *ResultPrePublish

func (*OracleAction) GetResultPublish 

func (m *OracleAction) GetResultPublish() *ResultPublish

func (*OracleAction) GetTy 

func (m *OracleAction) GetTy() int32

func (*OracleAction) GetValue 

func (m *OracleAction) GetValue() isOracleAction_Value

func (*OracleAction) ProtoMessage 

func (*OracleAction) ProtoMessage()

func (*OracleAction) Reset 

func (m *OracleAction) Reset()

func (*OracleAction) String 

func (m *OracleAction) String() string

func (*OracleAction) XXX_DiscardUnknown 

func (m *OracleAction) XXX_DiscardUnknown()

func (*OracleAction) XXX_Marshal 

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

func (*OracleAction) XXX_Merge 

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

func (*OracleAction) XXX_OneofFuncs 

func (*OracleAction) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*OracleAction) XXX_Size 

func (m *OracleAction) XXX_Size() int

func (*OracleAction) XXX_Unmarshal 

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

type OracleAction_EventAbort 

type OracleAction_EventAbort struct {
	EventAbort *EventAbort `protobuf:"bytes,2,opt,name=eventAbort,proto3,oneof"`
}

type OracleAction_EventPublish 

type OracleAction_EventPublish struct {
	EventPublish *EventPublish `protobuf:"bytes,1,opt,name=eventPublish,proto3,oneof"`
}

type OracleAction_ResultAbort 

type OracleAction_ResultAbort struct {
	ResultAbort *ResultAbort `protobuf:"bytes,5,opt,name=resultAbort,proto3,oneof"`
}

type OracleAction_ResultPrePublish 

type OracleAction_ResultPrePublish struct {
	ResultPrePublish *ResultPrePublish `protobuf:"bytes,3,opt,name=resultPrePublish,proto3,oneof"`
}

type OracleAction_ResultPublish 

type OracleAction_ResultPublish struct {
	ResultPublish *ResultPublish `protobuf:"bytes,4,opt,name=resultPublish,proto3,oneof"`
}

type OracleRow 

type OracleRow struct {
	*ReceiptOracle
}

OracleRow table meta 结构

func NewOracleRow 

func NewOracleRow() *OracleRow

NewOracleRow 新建一个meta 结构

func (*OracleRow) CreateRow 

func (tx *OracleRow) CreateRow() *table.Row

CreateRow 新建数据行(注意index 数据一定也要保存到数据中,不能就保存eventid)

func (*OracleRow) Get 

func (tx *OracleRow) Get(key string) ([]byte, error)

Get 按照indexName 查询 indexValue

func (*OracleRow) SetPayload 

func (tx *OracleRow) SetPayload(data types.Message) error

SetPayload 设置数据

type OracleStatus 

type OracleStatus struct {
	EventID              string       `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Addr                 string       `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Type                 string       `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	SubType              string       `protobuf:"bytes,4,opt,name=subType,proto3" json:"subType,omitempty"`
	Time                 int64        `protobuf:"varint,5,opt,name=time,proto3" json:"time,omitempty"`
	Content              string       `protobuf:"bytes,6,opt,name=content,proto3" json:"content,omitempty"`
	Introduction         string       `protobuf:"bytes,7,opt,name=introduction,proto3" json:"introduction,omitempty"`
	Status               *EventStatus `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	Source               string       `protobuf:"bytes,9,opt,name=source,proto3" json:"source,omitempty"`
	Result               string       `protobuf:"bytes,10,opt,name=result,proto3" json:"result,omitempty"`
	PreStatus            *EventStatus `protobuf:"bytes,11,opt,name=preStatus,proto3" json:"preStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

事件

func (*OracleStatus) Descriptor 

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

func (*OracleStatus) GetAddr 

func (m *OracleStatus) GetAddr() string

func (*OracleStatus) GetContent 

func (m *OracleStatus) GetContent() string

func (*OracleStatus) GetEventID 

func (m *OracleStatus) GetEventID() string

func (*OracleStatus) GetIntroduction 

func (m *OracleStatus) GetIntroduction() string

func (*OracleStatus) GetPreStatus 

func (m *OracleStatus) GetPreStatus() *EventStatus

func (*OracleStatus) GetResult 

func (m *OracleStatus) GetResult() string

func (*OracleStatus) GetSource 

func (m *OracleStatus) GetSource() string

func (*OracleStatus) GetStatus 

func (m *OracleStatus) GetStatus() *EventStatus

func (*OracleStatus) GetSubType 

func (m *OracleStatus) GetSubType() string

func (*OracleStatus) GetTime 

func (m *OracleStatus) GetTime() int64

func (*OracleStatus) GetType 

func (m *OracleStatus) GetType() string

func (*OracleStatus) ProtoMessage 

func (*OracleStatus) ProtoMessage()

func (*OracleStatus) Reset 

func (m *OracleStatus) Reset()

func (*OracleStatus) String 

func (m *OracleStatus) String() string

func (*OracleStatus) XXX_DiscardUnknown 

func (m *OracleStatus) XXX_DiscardUnknown()

func (*OracleStatus) XXX_Marshal 

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

func (*OracleStatus) XXX_Merge 

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

func (*OracleStatus) XXX_Size 

func (m *OracleStatus) XXX_Size() int

func (*OracleStatus) XXX_Unmarshal 

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

type OracleType 

type OracleType struct {
	types.ExecTypeBase
}

OracleType 预言机执行器类型

func NewType 

func NewType() *OracleType

NewType 创建执行器类型

func (*OracleType) GetLogMap 

func (o *OracleType) GetLogMap() map[int64]*types.LogInfo

GetLogMap 获取日志map

func (*OracleType) GetName 

func (o *OracleType) GetName() string

GetName 获取执行器名称

func (*OracleType) GetPayload 

func (o *OracleType) GetPayload() types.Message

GetPayload 获取oracle action

func (*OracleType) GetTypeMap 

func (o *OracleType) GetTypeMap() map[string]int32

GetTypeMap 获取类型map

type QueryEventID 

type QueryEventID struct {
	Status               int32    `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Addr                 string   `protobuf:"bytes,2,opt,name=addr,proto3" json:"addr,omitempty"`
	Type                 string   `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	EventID              string   `protobuf:"bytes,4,opt,name=eventID,proto3" json:"eventID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryEventID) Descriptor 

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

func (*QueryEventID) GetAddr 

func (m *QueryEventID) GetAddr() string

func (*QueryEventID) GetEventID 

func (m *QueryEventID) GetEventID() string

func (*QueryEventID) GetStatus 

func (m *QueryEventID) GetStatus() int32

func (*QueryEventID) GetType 

func (m *QueryEventID) GetType() string

func (*QueryEventID) ProtoMessage 

func (*QueryEventID) ProtoMessage()

func (*QueryEventID) Reset 

func (m *QueryEventID) Reset()

func (*QueryEventID) String 

func (m *QueryEventID) String() string

func (*QueryEventID) XXX_DiscardUnknown 

func (m *QueryEventID) XXX_DiscardUnknown()

func (*QueryEventID) XXX_Marshal 

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

func (*QueryEventID) XXX_Merge 

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

func (*QueryEventID) XXX_Size 

func (m *QueryEventID) XXX_Size() int

func (*QueryEventID) XXX_Unmarshal 

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

type QueryOracleInfos 

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

func (*QueryOracleInfos) Descriptor 

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

func (*QueryOracleInfos) GetEventID 

func (m *QueryOracleInfos) GetEventID() []string

func (*QueryOracleInfos) ProtoMessage 

func (*QueryOracleInfos) ProtoMessage()

func (*QueryOracleInfos) Reset 

func (m *QueryOracleInfos) Reset()

func (*QueryOracleInfos) String 

func (m *QueryOracleInfos) String() string

func (*QueryOracleInfos) XXX_DiscardUnknown 

func (m *QueryOracleInfos) XXX_DiscardUnknown()

func (*QueryOracleInfos) XXX_Marshal 

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

func (*QueryOracleInfos) XXX_Merge 

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

func (*QueryOracleInfos) XXX_Size 

func (m *QueryOracleInfos) XXX_Size() int

func (*QueryOracleInfos) XXX_Unmarshal 

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

type ReceiptOracle 

type ReceiptOracle struct {
	EventID              string   `protobuf:"bytes,1,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Status               int32    `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Addr                 string   `protobuf:"bytes,3,opt,name=addr,proto3" json:"addr,omitempty"`
	Type                 string   `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	PreStatus            int32    `protobuf:"varint,6,opt,name=preStatus,proto3" json:"preStatus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReceiptOracle) Descriptor 

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

func (*ReceiptOracle) GetAddr 

func (m *ReceiptOracle) GetAddr() string

func (*ReceiptOracle) GetEventID 

func (m *ReceiptOracle) GetEventID() string

func (*ReceiptOracle) GetPreStatus 

func (m *ReceiptOracle) GetPreStatus() int32

func (*ReceiptOracle) GetStatus 

func (m *ReceiptOracle) GetStatus() int32

func (*ReceiptOracle) GetType 

func (m *ReceiptOracle) GetType() string

func (*ReceiptOracle) ProtoMessage 

func (*ReceiptOracle) ProtoMessage()

func (*ReceiptOracle) Reset 

func (m *ReceiptOracle) Reset()

func (*ReceiptOracle) String 

func (m *ReceiptOracle) String() string

func (*ReceiptOracle) XXX_DiscardUnknown 

func (m *ReceiptOracle) XXX_DiscardUnknown()

func (*ReceiptOracle) XXX_Marshal 

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

func (*ReceiptOracle) XXX_Merge 

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

func (*ReceiptOracle) XXX_Size 

func (m *ReceiptOracle) XXX_Size() int

func (*ReceiptOracle) XXX_Unmarshal 

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

type ReplyEventIDs 

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

func (*ReplyEventIDs) Descriptor 

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

func (*ReplyEventIDs) GetEventID 

func (m *ReplyEventIDs) GetEventID() []string

func (*ReplyEventIDs) ProtoMessage 

func (*ReplyEventIDs) ProtoMessage()

func (*ReplyEventIDs) Reset 

func (m *ReplyEventIDs) Reset()

func (*ReplyEventIDs) String 

func (m *ReplyEventIDs) String() string

func (*ReplyEventIDs) XXX_DiscardUnknown 

func (m *ReplyEventIDs) XXX_DiscardUnknown()

func (*ReplyEventIDs) XXX_Marshal 

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

func (*ReplyEventIDs) XXX_Merge 

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

func (*ReplyEventIDs) XXX_Size 

func (m *ReplyEventIDs) XXX_Size() int

func (*ReplyEventIDs) XXX_Unmarshal 

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

type ReplyOracleStatusList 

type ReplyOracleStatusList struct {
	Status               []*OracleStatus `protobuf:"bytes,1,rep,name=status,proto3" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*ReplyOracleStatusList) Descriptor 

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

func (*ReplyOracleStatusList) GetStatus 

func (m *ReplyOracleStatusList) GetStatus() []*OracleStatus

func (*ReplyOracleStatusList) ProtoMessage 

func (*ReplyOracleStatusList) ProtoMessage()

func (*ReplyOracleStatusList) Reset 

func (m *ReplyOracleStatusList) Reset()

func (*ReplyOracleStatusList) String 

func (m *ReplyOracleStatusList) String() string

func (*ReplyOracleStatusList) XXX_DiscardUnknown 

func (m *ReplyOracleStatusList) XXX_DiscardUnknown()

func (*ReplyOracleStatusList) XXX_Marshal 

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

func (*ReplyOracleStatusList) XXX_Merge 

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

func (*ReplyOracleStatusList) XXX_Size 

func (m *ReplyOracleStatusList) XXX_Size() int

func (*ReplyOracleStatusList) XXX_Unmarshal 

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

type ResultAbort 

type ResultAbort struct {
	EventID              string   `protobuf:"bytes,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResultAbort) Descriptor 

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

func (*ResultAbort) GetEventID 

func (m *ResultAbort) GetEventID() string

func (*ResultAbort) ProtoMessage 

func (*ResultAbort) ProtoMessage()

func (*ResultAbort) Reset 

func (m *ResultAbort) Reset()

func (*ResultAbort) String 

func (m *ResultAbort) String() string

func (*ResultAbort) XXX_DiscardUnknown 

func (m *ResultAbort) XXX_DiscardUnknown()

func (*ResultAbort) XXX_Marshal 

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

func (*ResultAbort) XXX_Merge 

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

func (*ResultAbort) XXX_Size 

func (m *ResultAbort) XXX_Size() int

func (*ResultAbort) XXX_Unmarshal 

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

type ResultPrePublish 

type ResultPrePublish struct {
	EventID              string   `protobuf:"bytes,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Source               string   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Result               string   `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResultPrePublish) Descriptor 

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

func (*ResultPrePublish) GetEventID 

func (m *ResultPrePublish) GetEventID() string

func (*ResultPrePublish) GetResult 

func (m *ResultPrePublish) GetResult() string

func (*ResultPrePublish) GetSource 

func (m *ResultPrePublish) GetSource() string

func (*ResultPrePublish) ProtoMessage 

func (*ResultPrePublish) ProtoMessage()

func (*ResultPrePublish) Reset 

func (m *ResultPrePublish) Reset()

func (*ResultPrePublish) String 

func (m *ResultPrePublish) String() string

func (*ResultPrePublish) XXX_DiscardUnknown 

func (m *ResultPrePublish) XXX_DiscardUnknown()

func (*ResultPrePublish) XXX_Marshal 

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

func (*ResultPrePublish) XXX_Merge 

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

func (*ResultPrePublish) XXX_Size 

func (m *ResultPrePublish) XXX_Size() int

func (*ResultPrePublish) XXX_Unmarshal 

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

type ResultPublish 

type ResultPublish struct {
	EventID              string   `protobuf:"bytes,2,opt,name=eventID,proto3" json:"eventID,omitempty"`
	Source               string   `protobuf:"bytes,3,opt,name=source,proto3" json:"source,omitempty"`
	Result               string   `protobuf:"bytes,4,opt,name=result,proto3" json:"result,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResultPublish) Descriptor 

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

func (*ResultPublish) GetEventID 

func (m *ResultPublish) GetEventID() string

func (*ResultPublish) GetResult 

func (m *ResultPublish) GetResult() string

func (*ResultPublish) GetSource 

func (m *ResultPublish) GetSource() string

func (*ResultPublish) ProtoMessage 

func (*ResultPublish) ProtoMessage()

func (*ResultPublish) Reset 

func (m *ResultPublish) Reset()

func (*ResultPublish) String 

func (m *ResultPublish) String() string

func (*ResultPublish) XXX_DiscardUnknown 

func (m *ResultPublish) XXX_DiscardUnknown()

func (*ResultPublish) XXX_Marshal 

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

func (*ResultPublish) XXX_Merge 

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

func (*ResultPublish) XXX_Size 

func (m *ResultPublish) XXX_Size() int

func (*ResultPublish) XXX_Unmarshal 

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