types

package
v0.0.0-...-0abe6a2 Latest Latest
Warning

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

Go to latest
Published: Sep 19, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL