types

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2025 License: Apache-2.0 Imports: 17 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	CodeTypeOK uint32 = 0
)

Variables

View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var AVSI_serviceDesc = _AVSI_serviceDesc

Functions

func ReadMessage 

func ReadMessage(r io.Reader, msg proto.Message) error

ReadMessage reads a varint length-delimited protobuf message.

func RegisterAVSIServer 

func RegisterAVSIServer(s grpc1.Server, srv AVSIServer)

func WriteMessage 

func WriteMessage(msg proto.Message, w io.Writer) error

WriteMessage writes a varint length-delimited protobuf message.

Types

type AVSIClient 

type AVSIClient interface {
	Flush(ctx context.Context, in *RequestFlush, opts ...grpc.CallOption) (*ResponseFlush, error)
	// query
	Echo(ctx context.Context, in *RequestEcho, opts ...grpc.CallOption) (*ResponseEcho, error)
	Info(ctx context.Context, in *RequestInfo, opts ...grpc.CallOption) (*ResponseInfo, error)
	Query(ctx context.Context, in *RequestQuery, opts ...grpc.CallOption) (*ResponseQuery, error)
	// dvs request
	ProcessDVSRequest(ctx context.Context, in *RequestProcessDVSRequest, opts ...grpc.CallOption) (*ResponseProcessDVSRequest, error)
	ProcessDVSResponse(ctx context.Context, in *RequestProcessDVSResponse, opts ...grpc.CallOption) (*ResponseProcessDVSResponse, error)
}

AVSIClient is the client API for AVSI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewAVSIClient 

func NewAVSIClient(cc grpc1.ClientConn) AVSIClient

type AVSIServer 

type AVSIServer interface {
	Flush(context.Context, *RequestFlush) (*ResponseFlush, error)
	// query
	Echo(context.Context, *RequestEcho) (*ResponseEcho, error)
	Info(context.Context, *RequestInfo) (*ResponseInfo, error)
	Query(context.Context, *RequestQuery) (*ResponseQuery, error)
	// dvs request
	ProcessDVSRequest(context.Context, *RequestProcessDVSRequest) (*ResponseProcessDVSRequest, error)
	ProcessDVSResponse(context.Context, *RequestProcessDVSResponse) (*ResponseProcessDVSResponse, error)
}

AVSIServer is the server API for AVSI service.

type Application 

type Application interface {
	// Info/Query Connection
	Info(context.Context, *RequestInfo) (*ResponseInfo, error)    // Return application info
	Query(context.Context, *RequestQuery) (*ResponseQuery, error) // Query for state

	//dvs connection
	ProcessDVSRequest(context.Context, *RequestProcessDVSRequest) (*ResponseProcessDVSRequest, error)
	ProcessDVSResponse(context.Context, *RequestProcessDVSResponse) (*ResponseProcessDVSResponse, error)
}

Application is an interface that enables any finite, deterministic state machine to be driven by a blockchain-based replication engine via the AVSI.

type BaseApplication 

type BaseApplication struct{}

func NewBaseApplication 

func NewBaseApplication() *BaseApplication

func (BaseApplication) Info 

func (BaseApplication) Info(context.Context, *RequestInfo) (*ResponseInfo, error)

func (BaseApplication) ProcessDVSRequest 

func (BaseApplication) ProcessDVSRequest(context.Context, *RequestProcessDVSRequest) (*ResponseProcessDVSRequest, error)

func (BaseApplication) ProcessDVSResponse 

func (BaseApplication) ProcessDVSResponse(context.Context, *RequestProcessDVSResponse) (*ResponseProcessDVSResponse, error)

func (BaseApplication) Query 

func (BaseApplication) Query(context.Context, *RequestQuery) (*ResponseQuery, error)

type DVSRequest 

type DVSRequest struct {
	Data                      []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Height                    int64    `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	ChainId                   int64    `protobuf:"varint,3,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	GroupNumbers              []uint32 `protobuf:"varint,4,rep,packed,name=group_numbers,json=groupNumbers,proto3" json:"group_numbers,omitempty"`
	GroupThresholdPercentages []uint32 `` /* 146-byte string literal not displayed */
}

-----------------------------DVS----------------------------------

func (*DVSRequest) Descriptor 

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

func (*DVSRequest) GetChainId 

func (m *DVSRequest) GetChainId() int64

func (*DVSRequest) GetData 

func (m *DVSRequest) GetData() []byte

func (*DVSRequest) GetGroupNumbers 

func (m *DVSRequest) GetGroupNumbers() []uint32

func (*DVSRequest) GetGroupThresholdPercentages 

func (m *DVSRequest) GetGroupThresholdPercentages() []uint32

func (*DVSRequest) GetHeight 

func (m *DVSRequest) GetHeight() int64

func (*DVSRequest) Hash added in v0.3.1 

func (d *DVSRequest) Hash() DVSRequestHash

func (*DVSRequest) Marshal 

func (m *DVSRequest) Marshal() (dAtA []byte, err error)

func (*DVSRequest) MarshalTo 

func (m *DVSRequest) MarshalTo(dAtA []byte) (int, error)

func (*DVSRequest) MarshalToSizedBuffer 

func (m *DVSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DVSRequest) ProtoMessage 

func (*DVSRequest) ProtoMessage()

func (*DVSRequest) Reset 

func (m *DVSRequest) Reset()

func (*DVSRequest) Size 

func (m *DVSRequest) Size() (n int)

func (*DVSRequest) String 

func (m *DVSRequest) String() string

func (*DVSRequest) Unmarshal 

func (m *DVSRequest) Unmarshal(dAtA []byte) error

func (*DVSRequest) XXX_DiscardUnknown 

func (m *DVSRequest) XXX_DiscardUnknown()

func (*DVSRequest) XXX_Marshal 

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

func (*DVSRequest) XXX_Merge 

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

func (*DVSRequest) XXX_Size 

func (m *DVSRequest) XXX_Size() int

func (*DVSRequest) XXX_Unmarshal 

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

type DVSRequestHash added in v0.3.1 

type DVSRequestHash []byte

type DVSRequestResult 

type DVSRequestResult struct {
	DvsRequest                 *DVSRequest                 `protobuf:"bytes,1,opt,name=dvs_request,json=dvsRequest,proto3" json:"dvs_request,omitempty"`
	ResponseProcessDvsRequest  *ResponseProcessDVSRequest  `` /* 140-byte string literal not displayed */
	DvsResponse                *DVSResponse                `protobuf:"bytes,3,opt,name=dvs_response,json=dvsResponse,proto3" json:"dvs_response,omitempty"`
	ResponseProcessDvsResponse *ResponseProcessDVSResponse `` /* 143-byte string literal not displayed */
}

-------------------- dvs request result idx

func (*DVSRequestResult) Descriptor 

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

func (*DVSRequestResult) GetDvsRequest 

func (m *DVSRequestResult) GetDvsRequest() *DVSRequest

func (*DVSRequestResult) GetDvsResponse 

func (m *DVSRequestResult) GetDvsResponse() *DVSResponse

func (*DVSRequestResult) GetResponseProcessDvsRequest 

func (m *DVSRequestResult) GetResponseProcessDvsRequest() *ResponseProcessDVSRequest

func (*DVSRequestResult) GetResponseProcessDvsResponse 

func (m *DVSRequestResult) GetResponseProcessDvsResponse() *ResponseProcessDVSResponse

func (*DVSRequestResult) Marshal 

func (m *DVSRequestResult) Marshal() (dAtA []byte, err error)

func (*DVSRequestResult) MarshalTo 

func (m *DVSRequestResult) MarshalTo(dAtA []byte) (int, error)

func (*DVSRequestResult) MarshalToSizedBuffer 

func (m *DVSRequestResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DVSRequestResult) ProtoMessage 

func (*DVSRequestResult) ProtoMessage()

func (*DVSRequestResult) Reset 

func (m *DVSRequestResult) Reset()

func (*DVSRequestResult) Size 

func (m *DVSRequestResult) Size() (n int)

func (*DVSRequestResult) String 

func (m *DVSRequestResult) String() string

func (*DVSRequestResult) Unmarshal 

func (m *DVSRequestResult) Unmarshal(dAtA []byte) error

func (*DVSRequestResult) XXX_DiscardUnknown 

func (m *DVSRequestResult) XXX_DiscardUnknown()

func (*DVSRequestResult) XXX_Marshal 

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

func (*DVSRequestResult) XXX_Merge 

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

func (*DVSRequestResult) XXX_Size 

func (m *DVSRequestResult) XXX_Size() int

func (*DVSRequestResult) XXX_Unmarshal 

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

type DVSResponse 

type DVSResponse struct {
	Data                        []byte                  `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Error                       string                  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Hash                        []byte                  `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	NonSignersPubkeysG1         [][]byte                `protobuf:"bytes,4,rep,name=non_signers_pubkeys_g1,json=nonSignersPubkeysG1,proto3" json:"non_signers_pubkeys_g1,omitempty"`
	GroupApksG1                 [][]byte                `protobuf:"bytes,5,rep,name=group_apks_g1,json=groupApksG1,proto3" json:"group_apks_g1,omitempty"`
	SignersApkG2                []byte                  `protobuf:"bytes,6,opt,name=signers_apk_g2,json=signersApkG2,proto3" json:"signers_apk_g2,omitempty"`
	SignersAggSigG1             []byte                  `protobuf:"bytes,7,opt,name=signers_agg_sig_g1,json=signersAggSigG1,proto3" json:"signers_agg_sig_g1,omitempty"`
	NonSignerGroupBitmapIndices []uint32                `` /* 156-byte string literal not displayed */
	GroupApkIndices             []uint32                `protobuf:"varint,9,rep,packed,name=group_apk_indices,json=groupApkIndices,proto3" json:"group_apk_indices,omitempty"`
	TotalStakeIndices           []uint32                `protobuf:"varint,10,rep,packed,name=total_stake_indices,json=totalStakeIndices,proto3" json:"total_stake_indices,omitempty"`
	NonSignerStakeIndices       []*NonSignerStakeIndice `` /* 129-byte string literal not displayed */
}

-------------------- DVSResponse

func (*DVSResponse) Descriptor 

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

func (*DVSResponse) GetData 

func (m *DVSResponse) GetData() []byte

func (*DVSResponse) GetError 

func (m *DVSResponse) GetError() string

func (*DVSResponse) GetGroupApkIndices 

func (m *DVSResponse) GetGroupApkIndices() []uint32

func (*DVSResponse) GetGroupApksG1 

func (m *DVSResponse) GetGroupApksG1() [][]byte

func (*DVSResponse) GetHash 

func (m *DVSResponse) GetHash() []byte

func (*DVSResponse) GetNonSignerGroupBitmapIndices 

func (m *DVSResponse) GetNonSignerGroupBitmapIndices() []uint32

func (*DVSResponse) GetNonSignerStakeIndices 

func (m *DVSResponse) GetNonSignerStakeIndices() []*NonSignerStakeIndice

func (*DVSResponse) GetNonSignersPubkeysG1 

func (m *DVSResponse) GetNonSignersPubkeysG1() [][]byte

func (*DVSResponse) GetSignersAggSigG1 

func (m *DVSResponse) GetSignersAggSigG1() []byte

func (*DVSResponse) GetSignersApkG2 

func (m *DVSResponse) GetSignersApkG2() []byte

func (*DVSResponse) GetTotalStakeIndices 

func (m *DVSResponse) GetTotalStakeIndices() []uint32

func (*DVSResponse) Marshal 

func (m *DVSResponse) Marshal() (dAtA []byte, err error)

func (*DVSResponse) MarshalTo 

func (m *DVSResponse) MarshalTo(dAtA []byte) (int, error)

func (*DVSResponse) MarshalToSizedBuffer 

func (m *DVSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DVSResponse) ProtoMessage 

func (*DVSResponse) ProtoMessage()

func (*DVSResponse) Reset 

func (m *DVSResponse) Reset()

func (*DVSResponse) Size 

func (m *DVSResponse) Size() (n int)

func (*DVSResponse) String 

func (m *DVSResponse) String() string

func (*DVSResponse) Unmarshal 

func (m *DVSResponse) Unmarshal(dAtA []byte) error

func (*DVSResponse) XXX_DiscardUnknown 

func (m *DVSResponse) XXX_DiscardUnknown()

func (*DVSResponse) XXX_Marshal 

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

func (*DVSResponse) XXX_Merge 

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

func (*DVSResponse) XXX_Size 

func (m *DVSResponse) XXX_Size() int

func (*DVSResponse) XXX_Unmarshal 

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

type Event 

type Event struct {
	Type       string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Attributes []EventAttribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"`
}

func (*Event) Descriptor 

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

func (*Event) GetAttributes 

func (m *Event) GetAttributes() []EventAttribute

func (*Event) GetType 

func (m *Event) GetType() string

func (*Event) Marshal 

func (m *Event) Marshal() (dAtA []byte, err error)

func (*Event) MarshalTo 

func (m *Event) MarshalTo(dAtA []byte) (int, error)

func (*Event) MarshalToSizedBuffer 

func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) Reset 

func (m *Event) Reset()

func (*Event) Size 

func (m *Event) Size() (n int)

func (*Event) String 

func (m *Event) String() string

func (*Event) Unmarshal 

func (m *Event) Unmarshal(dAtA []byte) error

func (*Event) XXX_DiscardUnknown 

func (m *Event) XXX_DiscardUnknown()

func (*Event) XXX_Marshal 

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

func (*Event) XXX_Merge 

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

func (*Event) XXX_Size 

func (m *Event) XXX_Size() int

func (*Event) XXX_Unmarshal 

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

type EventAttribute 

type EventAttribute struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Index bool   `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
}

func (*EventAttribute) Descriptor 

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

func (*EventAttribute) GetIndex 

func (m *EventAttribute) GetIndex() bool

func (*EventAttribute) GetKey 

func (m *EventAttribute) GetKey() string

func (*EventAttribute) GetValue 

func (m *EventAttribute) GetValue() string

func (*EventAttribute) Marshal 

func (m *EventAttribute) Marshal() (dAtA []byte, err error)

func (*EventAttribute) MarshalTo 

func (m *EventAttribute) MarshalTo(dAtA []byte) (int, error)

func (*EventAttribute) MarshalToSizedBuffer 

func (m *EventAttribute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EventAttribute) ProtoMessage 

func (*EventAttribute) ProtoMessage()

func (*EventAttribute) Reset 

func (m *EventAttribute) Reset()

func (*EventAttribute) Size 

func (m *EventAttribute) Size() (n int)

func (*EventAttribute) String 

func (m *EventAttribute) String() string

func (*EventAttribute) Unmarshal 

func (m *EventAttribute) Unmarshal(dAtA []byte) error

func (*EventAttribute) XXX_DiscardUnknown 

func (m *EventAttribute) XXX_DiscardUnknown()

func (*EventAttribute) XXX_Marshal 

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

func (*EventAttribute) XXX_Merge 

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

func (*EventAttribute) XXX_Size 

func (m *EventAttribute) XXX_Size() int

func (*EventAttribute) XXX_Unmarshal 

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

type NonSignerStakeIndice 

type NonSignerStakeIndice struct {
	NonSignerStakeIndice []uint32 `` /* 133-byte string literal not displayed */
}

func (*NonSignerStakeIndice) Descriptor 

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

func (*NonSignerStakeIndice) GetNonSignerStakeIndice 

func (m *NonSignerStakeIndice) GetNonSignerStakeIndice() []uint32

func (*NonSignerStakeIndice) Marshal 

func (m *NonSignerStakeIndice) Marshal() (dAtA []byte, err error)

func (*NonSignerStakeIndice) MarshalTo 

func (m *NonSignerStakeIndice) MarshalTo(dAtA []byte) (int, error)

func (*NonSignerStakeIndice) MarshalToSizedBuffer 

func (m *NonSignerStakeIndice) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*NonSignerStakeIndice) ProtoMessage 

func (*NonSignerStakeIndice) ProtoMessage()

func (*NonSignerStakeIndice) Reset 

func (m *NonSignerStakeIndice) Reset()

func (*NonSignerStakeIndice) Size 

func (m *NonSignerStakeIndice) Size() (n int)

func (*NonSignerStakeIndice) String 

func (m *NonSignerStakeIndice) String() string

func (*NonSignerStakeIndice) Unmarshal 

func (m *NonSignerStakeIndice) Unmarshal(dAtA []byte) error

func (*NonSignerStakeIndice) XXX_DiscardUnknown 

func (m *NonSignerStakeIndice) XXX_DiscardUnknown()

func (*NonSignerStakeIndice) XXX_Marshal 

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

func (*NonSignerStakeIndice) XXX_Merge 

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

func (*NonSignerStakeIndice) XXX_Size 

func (m *NonSignerStakeIndice) XXX_Size() int

func (*NonSignerStakeIndice) XXX_Unmarshal 

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

type Operator 

type Operator struct {
	Id      []byte           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address []byte           `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	MetaUri string           `protobuf:"bytes,3,opt,name=meta_uri,json=metaUri,proto3" json:"meta_uri,omitempty"`
	Socket  string           `protobuf:"bytes,4,opt,name=socket,proto3" json:"socket,omitempty"`
	Stake   int64            `protobuf:"varint,5,opt,name=stake,proto3" json:"stake,omitempty"`
	Pubkeys *OperatorPubkeys `protobuf:"bytes,6,opt,name=pubkeys,proto3" json:"pubkeys,omitempty"`
}

func (*Operator) Descriptor 

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

func (*Operator) GetAddress 

func (m *Operator) GetAddress() []byte

func (*Operator) GetId 

func (m *Operator) GetId() []byte

func (*Operator) GetMetaUri 

func (m *Operator) GetMetaUri() string

func (*Operator) GetPubkeys 

func (m *Operator) GetPubkeys() *OperatorPubkeys

func (*Operator) GetSocket 

func (m *Operator) GetSocket() string

func (*Operator) GetStake 

func (m *Operator) GetStake() int64

func (*Operator) Marshal 

func (m *Operator) Marshal() (dAtA []byte, err error)

func (*Operator) MarshalTo 

func (m *Operator) MarshalTo(dAtA []byte) (int, error)

func (*Operator) MarshalToSizedBuffer 

func (m *Operator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) Reset 

func (m *Operator) Reset()

func (*Operator) Size 

func (m *Operator) Size() (n int)

func (*Operator) String 

func (m *Operator) String() string

func (*Operator) Unmarshal 

func (m *Operator) Unmarshal(dAtA []byte) error

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

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

func (*Operator) XXX_Merge 

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

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

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

type OperatorPubkeys 

type OperatorPubkeys struct {
	G1Pubkey []byte `protobuf:"bytes,1,opt,name=g1_pubkey,json=g1Pubkey,proto3" json:"g1_pubkey,omitempty"`
	G2Pubkey []byte `protobuf:"bytes,2,opt,name=g2_pubkey,json=g2Pubkey,proto3" json:"g2_pubkey,omitempty"`
}

func (*OperatorPubkeys) Descriptor 

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

func (*OperatorPubkeys) GetG1Pubkey 

func (m *OperatorPubkeys) GetG1Pubkey() []byte

func (*OperatorPubkeys) GetG2Pubkey 

func (m *OperatorPubkeys) GetG2Pubkey() []byte

func (*OperatorPubkeys) Marshal 

func (m *OperatorPubkeys) Marshal() (dAtA []byte, err error)

func (*OperatorPubkeys) MarshalTo 

func (m *OperatorPubkeys) MarshalTo(dAtA []byte) (int, error)

func (*OperatorPubkeys) MarshalToSizedBuffer 

func (m *OperatorPubkeys) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperatorPubkeys) ProtoMessage 

func (*OperatorPubkeys) ProtoMessage()

func (*OperatorPubkeys) Reset 

func (m *OperatorPubkeys) Reset()

func (*OperatorPubkeys) Size 

func (m *OperatorPubkeys) Size() (n int)

func (*OperatorPubkeys) String 

func (m *OperatorPubkeys) String() string

func (*OperatorPubkeys) Unmarshal 

func (m *OperatorPubkeys) Unmarshal(dAtA []byte) error

func (*OperatorPubkeys) XXX_DiscardUnknown 

func (m *OperatorPubkeys) XXX_DiscardUnknown()

func (*OperatorPubkeys) XXX_Marshal 

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

func (*OperatorPubkeys) XXX_Merge 

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

func (*OperatorPubkeys) XXX_Size 

func (m *OperatorPubkeys) XXX_Size() int

func (*OperatorPubkeys) XXX_Unmarshal 

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

type Request 

type Request struct {
	// Types that are valid to be assigned to Value:
	//	*Request_Flush
	//	*Request_Echo
	//	*Request_Info
	//	*Request_Query
	//	*Request_ProcessDvsRequest
	//	*Request_ProcessDvsResponse
	Value isRequest_Value `protobuf_oneof:"value"`
}

---------------------------------------- Request types

func ToRequestEcho 

func ToRequestEcho(message string) *Request

func ToRequestFlush 

func ToRequestFlush() *Request

func ToRequestInfo 

func ToRequestInfo(req *RequestInfo) *Request

func ToRequestProcessDvsRequest 

func ToRequestProcessDvsRequest(req *RequestProcessDVSRequest) *Request

func ToRequestProcessDvsResponse 

func ToRequestProcessDvsResponse(req *RequestProcessDVSResponse) *Request

func ToRequestQuery 

func ToRequestQuery(req *RequestQuery) *Request

func (*Request) Descriptor 

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

func (*Request) GetEcho 

func (m *Request) GetEcho() *RequestEcho

func (*Request) GetFlush 

func (m *Request) GetFlush() *RequestFlush

func (*Request) GetInfo 

func (m *Request) GetInfo() *RequestInfo

func (*Request) GetProcessDvsRequest 

func (m *Request) GetProcessDvsRequest() *RequestProcessDVSRequest

func (*Request) GetProcessDvsResponse 

func (m *Request) GetProcessDvsResponse() *RequestProcessDVSResponse

func (*Request) GetQuery 

func (m *Request) GetQuery() *RequestQuery

func (*Request) GetValue 

func (m *Request) GetValue() isRequest_Value

func (*Request) Marshal 

func (m *Request) Marshal() (dAtA []byte, err error)

func (*Request) MarshalTo 

func (m *Request) MarshalTo(dAtA []byte) (int, error)

func (*Request) MarshalToSizedBuffer 

func (m *Request) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) Size 

func (m *Request) Size() (n int)

func (*Request) String 

func (m *Request) String() string

func (*Request) Unmarshal 

func (m *Request) Unmarshal(dAtA []byte) error

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_OneofWrappers 

func (*Request) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type RequestEcho 

type RequestEcho struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*RequestEcho) Descriptor 

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

func (*RequestEcho) GetMessage 

func (m *RequestEcho) GetMessage() string

func (*RequestEcho) Marshal 

func (m *RequestEcho) Marshal() (dAtA []byte, err error)

func (*RequestEcho) MarshalTo 

func (m *RequestEcho) MarshalTo(dAtA []byte) (int, error)

func (*RequestEcho) MarshalToSizedBuffer 

func (m *RequestEcho) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestEcho) ProtoMessage 

func (*RequestEcho) ProtoMessage()

func (*RequestEcho) Reset 

func (m *RequestEcho) Reset()

func (*RequestEcho) Size 

func (m *RequestEcho) Size() (n int)

func (*RequestEcho) String 

func (m *RequestEcho) String() string

func (*RequestEcho) Unmarshal 

func (m *RequestEcho) Unmarshal(dAtA []byte) error

func (*RequestEcho) XXX_DiscardUnknown 

func (m *RequestEcho) XXX_DiscardUnknown()

func (*RequestEcho) XXX_Marshal 

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

func (*RequestEcho) XXX_Merge 

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

func (*RequestEcho) XXX_Size 

func (m *RequestEcho) XXX_Size() int

func (*RequestEcho) XXX_Unmarshal 

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

type RequestFlush 

type RequestFlush struct {
}

TODO: Adapt to our business logic -----------------------------reserver----------------------------------

func (*RequestFlush) Descriptor 

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

func (*RequestFlush) Marshal 

func (m *RequestFlush) Marshal() (dAtA []byte, err error)

func (*RequestFlush) MarshalTo 

func (m *RequestFlush) MarshalTo(dAtA []byte) (int, error)

func (*RequestFlush) MarshalToSizedBuffer 

func (m *RequestFlush) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestFlush) ProtoMessage 

func (*RequestFlush) ProtoMessage()

func (*RequestFlush) Reset 

func (m *RequestFlush) Reset()

func (*RequestFlush) Size 

func (m *RequestFlush) Size() (n int)

func (*RequestFlush) String 

func (m *RequestFlush) String() string

func (*RequestFlush) Unmarshal 

func (m *RequestFlush) Unmarshal(dAtA []byte) error

func (*RequestFlush) XXX_DiscardUnknown 

func (m *RequestFlush) XXX_DiscardUnknown()

func (*RequestFlush) XXX_Marshal 

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

func (*RequestFlush) XXX_Merge 

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

func (*RequestFlush) XXX_Size 

func (m *RequestFlush) XXX_Size() int

func (*RequestFlush) XXX_Unmarshal 

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

type RequestInfo 

type RequestInfo struct {
	Version      string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	BlockVersion uint64 `protobuf:"varint,2,opt,name=block_version,json=blockVersion,proto3" json:"block_version,omitempty"`
	P2PVersion   uint64 `protobuf:"varint,3,opt,name=p2p_version,json=p2pVersion,proto3" json:"p2p_version,omitempty"`
	AbciVersion  string `protobuf:"bytes,4,opt,name=abci_version,json=abciVersion,proto3" json:"abci_version,omitempty"`
}

func (*RequestInfo) Descriptor 

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

func (*RequestInfo) GetAbciVersion 

func (m *RequestInfo) GetAbciVersion() string

func (*RequestInfo) GetBlockVersion 

func (m *RequestInfo) GetBlockVersion() uint64

func (*RequestInfo) GetP2PVersion 

func (m *RequestInfo) GetP2PVersion() uint64

func (*RequestInfo) GetVersion 

func (m *RequestInfo) GetVersion() string

func (*RequestInfo) Marshal 

func (m *RequestInfo) Marshal() (dAtA []byte, err error)

func (*RequestInfo) MarshalTo 

func (m *RequestInfo) MarshalTo(dAtA []byte) (int, error)

func (*RequestInfo) MarshalToSizedBuffer 

func (m *RequestInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestInfo) ProtoMessage 

func (*RequestInfo) ProtoMessage()

func (*RequestInfo) Reset 

func (m *RequestInfo) Reset()

func (*RequestInfo) Size 

func (m *RequestInfo) Size() (n int)

func (*RequestInfo) String 

func (m *RequestInfo) String() string

func (*RequestInfo) Unmarshal 

func (m *RequestInfo) Unmarshal(dAtA []byte) error

func (*RequestInfo) XXX_DiscardUnknown 

func (m *RequestInfo) XXX_DiscardUnknown()

func (*RequestInfo) XXX_Marshal 

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

func (*RequestInfo) XXX_Merge 

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

func (*RequestInfo) XXX_Size 

func (m *RequestInfo) XXX_Size() int

func (*RequestInfo) XXX_Unmarshal 

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

type RequestProcessDVSRequest 

type RequestProcessDVSRequest struct {
	Request  *DVSRequest `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Operator []*Operator `protobuf:"bytes,2,rep,name=operator,proto3" json:"operator,omitempty"`
}

func (*RequestProcessDVSRequest) Descriptor 

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

func (*RequestProcessDVSRequest) GetOperator 

func (m *RequestProcessDVSRequest) GetOperator() []*Operator

func (*RequestProcessDVSRequest) GetRequest 

func (m *RequestProcessDVSRequest) GetRequest() *DVSRequest

func (*RequestProcessDVSRequest) Marshal 

func (m *RequestProcessDVSRequest) Marshal() (dAtA []byte, err error)

func (*RequestProcessDVSRequest) MarshalTo 

func (m *RequestProcessDVSRequest) MarshalTo(dAtA []byte) (int, error)

func (*RequestProcessDVSRequest) MarshalToSizedBuffer 

func (m *RequestProcessDVSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestProcessDVSRequest) ProtoMessage 

func (*RequestProcessDVSRequest) ProtoMessage()

func (*RequestProcessDVSRequest) Reset 

func (m *RequestProcessDVSRequest) Reset()

func (*RequestProcessDVSRequest) Size 

func (m *RequestProcessDVSRequest) Size() (n int)

func (*RequestProcessDVSRequest) String 

func (m *RequestProcessDVSRequest) String() string

func (*RequestProcessDVSRequest) Unmarshal 

func (m *RequestProcessDVSRequest) Unmarshal(dAtA []byte) error

func (*RequestProcessDVSRequest) XXX_DiscardUnknown 

func (m *RequestProcessDVSRequest) XXX_DiscardUnknown()

func (*RequestProcessDVSRequest) XXX_Marshal 

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

func (*RequestProcessDVSRequest) XXX_Merge 

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

func (*RequestProcessDVSRequest) XXX_Size 

func (m *RequestProcessDVSRequest) XXX_Size() int

func (*RequestProcessDVSRequest) XXX_Unmarshal 

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

type RequestProcessDVSResponse 

type RequestProcessDVSResponse struct {
	DvsRequest  *DVSRequest  `protobuf:"bytes,1,opt,name=dvs_request,json=dvsRequest,proto3" json:"dvs_request,omitempty"`
	DvsResponse *DVSResponse `protobuf:"bytes,2,opt,name=dvs_response,json=dvsResponse,proto3" json:"dvs_response,omitempty"`
}

func (*RequestProcessDVSResponse) Descriptor 

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

func (*RequestProcessDVSResponse) GetDvsRequest 

func (m *RequestProcessDVSResponse) GetDvsRequest() *DVSRequest

func (*RequestProcessDVSResponse) GetDvsResponse 

func (m *RequestProcessDVSResponse) GetDvsResponse() *DVSResponse

func (*RequestProcessDVSResponse) Marshal 

func (m *RequestProcessDVSResponse) Marshal() (dAtA []byte, err error)

func (*RequestProcessDVSResponse) MarshalTo 

func (m *RequestProcessDVSResponse) MarshalTo(dAtA []byte) (int, error)

func (*RequestProcessDVSResponse) MarshalToSizedBuffer 

func (m *RequestProcessDVSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestProcessDVSResponse) ProtoMessage 

func (*RequestProcessDVSResponse) ProtoMessage()

func (*RequestProcessDVSResponse) Reset 

func (m *RequestProcessDVSResponse) Reset()

func (*RequestProcessDVSResponse) Size 

func (m *RequestProcessDVSResponse) Size() (n int)

func (*RequestProcessDVSResponse) String 

func (m *RequestProcessDVSResponse) String() string

func (*RequestProcessDVSResponse) Unmarshal 

func (m *RequestProcessDVSResponse) Unmarshal(dAtA []byte) error

func (*RequestProcessDVSResponse) XXX_DiscardUnknown 

func (m *RequestProcessDVSResponse) XXX_DiscardUnknown()

func (*RequestProcessDVSResponse) XXX_Marshal 

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

func (*RequestProcessDVSResponse) XXX_Merge 

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

func (*RequestProcessDVSResponse) XXX_Size 

func (m *RequestProcessDVSResponse) XXX_Size() int

func (*RequestProcessDVSResponse) XXX_Unmarshal 

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

type RequestQuery 

type RequestQuery struct {
	Data   []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Height int64  `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	Prove  bool   `protobuf:"varint,4,opt,name=prove,proto3" json:"prove,omitempty"`
}

func (*RequestQuery) Descriptor 

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

func (*RequestQuery) GetData 

func (m *RequestQuery) GetData() []byte

func (*RequestQuery) GetHeight 

func (m *RequestQuery) GetHeight() int64

func (*RequestQuery) GetPath 

func (m *RequestQuery) GetPath() string

func (*RequestQuery) GetProve 

func (m *RequestQuery) GetProve() bool

func (*RequestQuery) Marshal 

func (m *RequestQuery) Marshal() (dAtA []byte, err error)

func (*RequestQuery) MarshalTo 

func (m *RequestQuery) MarshalTo(dAtA []byte) (int, error)

func (*RequestQuery) MarshalToSizedBuffer 

func (m *RequestQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestQuery) ProtoMessage 

func (*RequestQuery) ProtoMessage()

func (*RequestQuery) Reset 

func (m *RequestQuery) Reset()

func (*RequestQuery) Size 

func (m *RequestQuery) Size() (n int)

func (*RequestQuery) String 

func (m *RequestQuery) String() string

func (*RequestQuery) Unmarshal 

func (m *RequestQuery) Unmarshal(dAtA []byte) error

func (*RequestQuery) XXX_DiscardUnknown 

func (m *RequestQuery) XXX_DiscardUnknown()

func (*RequestQuery) XXX_Marshal 

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

func (*RequestQuery) XXX_Merge 

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

func (*RequestQuery) XXX_Size 

func (m *RequestQuery) XXX_Size() int

func (*RequestQuery) XXX_Unmarshal 

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

type Request_Echo 

type Request_Echo struct {
	Echo *RequestEcho `protobuf:"bytes,2,opt,name=echo,proto3,oneof" json:"echo,omitempty"`
}

func (*Request_Echo) MarshalTo 

func (m *Request_Echo) MarshalTo(dAtA []byte) (int, error)

func (*Request_Echo) MarshalToSizedBuffer 

func (m *Request_Echo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request_Echo) Size 

func (m *Request_Echo) Size() (n int)

type Request_Flush 

type Request_Flush struct {
	Flush *RequestFlush `protobuf:"bytes,1,opt,name=flush,proto3,oneof" json:"flush,omitempty"`
}

func (*Request_Flush) MarshalTo 

func (m *Request_Flush) MarshalTo(dAtA []byte) (int, error)

func (*Request_Flush) MarshalToSizedBuffer 

func (m *Request_Flush) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request_Flush) Size 

func (m *Request_Flush) Size() (n int)

type Request_Info 

type Request_Info struct {
	Info *RequestInfo `protobuf:"bytes,3,opt,name=info,proto3,oneof" json:"info,omitempty"`
}

func (*Request_Info) MarshalTo 

func (m *Request_Info) MarshalTo(dAtA []byte) (int, error)

func (*Request_Info) MarshalToSizedBuffer 

func (m *Request_Info) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request_Info) Size 

func (m *Request_Info) Size() (n int)

type Request_ProcessDvsRequest 

type Request_ProcessDvsRequest struct {
	ProcessDvsRequest *RequestProcessDVSRequest `protobuf:"bytes,5,opt,name=process_dvs_request,json=processDvsRequest,proto3,oneof" json:"process_dvs_request,omitempty"`
}

func (*Request_ProcessDvsRequest) MarshalTo 

func (m *Request_ProcessDvsRequest) MarshalTo(dAtA []byte) (int, error)

func (*Request_ProcessDvsRequest) MarshalToSizedBuffer 

func (m *Request_ProcessDvsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request_ProcessDvsRequest) Size 

func (m *Request_ProcessDvsRequest) Size() (n int)

type Request_ProcessDvsResponse 

type Request_ProcessDvsResponse struct {
	ProcessDvsResponse *RequestProcessDVSResponse `protobuf:"bytes,6,opt,name=process_dvs_response,json=processDvsResponse,proto3,oneof" json:"process_dvs_response,omitempty"`
}

func (*Request_ProcessDvsResponse) MarshalTo 

func (m *Request_ProcessDvsResponse) MarshalTo(dAtA []byte) (int, error)

func (*Request_ProcessDvsResponse) MarshalToSizedBuffer 

func (m *Request_ProcessDvsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request_ProcessDvsResponse) Size 

func (m *Request_ProcessDvsResponse) Size() (n int)

type Request_Query 

type Request_Query struct {
	Query *RequestQuery `protobuf:"bytes,4,opt,name=query,proto3,oneof" json:"query,omitempty"`
}

func (*Request_Query) MarshalTo 

func (m *Request_Query) MarshalTo(dAtA []byte) (int, error)

func (*Request_Query) MarshalToSizedBuffer 

func (m *Request_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Request_Query) Size 

func (m *Request_Query) Size() (n int)

type Response 

type Response struct {
	// Types that are valid to be assigned to Value:
	//	*Response_Exception
	//	*Response_Flush
	//	*Response_Echo
	//	*Response_Info
	//	*Response_Query
	//	*Response_ProcessDvsRequest
	//	*Response_ProcessDvsResponse
	Value isResponse_Value `protobuf_oneof:"value"`
}

Response types

func ToResponseEcho 

func ToResponseEcho(message string) *Response

func ToResponseException 

func ToResponseException(message string) *Response

func ToResponseFlush 

func ToResponseFlush() *Response

func ToResponseInfo 

func ToResponseInfo(res *ResponseInfo) *Response

func ToResponseProcessDVSResponse 

func ToResponseProcessDVSResponse(res *ResponseProcessDVSResponse) *Response

func ToResponseProcessRequest 

func ToResponseProcessRequest(res *ResponseProcessDVSRequest) *Response

func ToResponseQuery 

func ToResponseQuery(res *ResponseQuery) *Response

func (*Response) Descriptor 

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

func (*Response) GetEcho 

func (m *Response) GetEcho() *ResponseEcho

func (*Response) GetException 

func (m *Response) GetException() *ResponseException

func (*Response) GetFlush 

func (m *Response) GetFlush() *ResponseFlush

func (*Response) GetInfo 

func (m *Response) GetInfo() *ResponseInfo

func (*Response) GetProcessDvsRequest 

func (m *Response) GetProcessDvsRequest() *ResponseProcessDVSRequest

func (*Response) GetProcessDvsResponse 

func (m *Response) GetProcessDvsResponse() *ResponseProcessDVSResponse

func (*Response) GetQuery 

func (m *Response) GetQuery() *ResponseQuery

func (*Response) GetValue 

func (m *Response) GetValue() isResponse_Value

func (*Response) Marshal 

func (m *Response) Marshal() (dAtA []byte, err error)

func (*Response) MarshalTo 

func (m *Response) MarshalTo(dAtA []byte) (int, error)

func (*Response) MarshalToSizedBuffer 

func (m *Response) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) Reset 

func (m *Response) Reset()

func (*Response) Size 

func (m *Response) Size() (n int)

func (*Response) String 

func (m *Response) String() string

func (*Response) Unmarshal 

func (m *Response) Unmarshal(dAtA []byte) error

func (*Response) XXX_DiscardUnknown 

func (m *Response) XXX_DiscardUnknown()

func (*Response) XXX_Marshal 

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

func (*Response) XXX_Merge 

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

func (*Response) XXX_OneofWrappers 

func (*Response) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Response) XXX_Size 

func (m *Response) XXX_Size() int

func (*Response) XXX_Unmarshal 

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

type ResponseEcho 

type ResponseEcho struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

func (*ResponseEcho) Descriptor 

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

func (*ResponseEcho) GetMessage 

func (m *ResponseEcho) GetMessage() string

func (*ResponseEcho) Marshal 

func (m *ResponseEcho) Marshal() (dAtA []byte, err error)

func (*ResponseEcho) MarshalTo 

func (m *ResponseEcho) MarshalTo(dAtA []byte) (int, error)

func (*ResponseEcho) MarshalToSizedBuffer 

func (m *ResponseEcho) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseEcho) ProtoMessage 

func (*ResponseEcho) ProtoMessage()

func (*ResponseEcho) Reset 

func (m *ResponseEcho) Reset()

func (*ResponseEcho) Size 

func (m *ResponseEcho) Size() (n int)

func (*ResponseEcho) String 

func (m *ResponseEcho) String() string

func (*ResponseEcho) Unmarshal 

func (m *ResponseEcho) Unmarshal(dAtA []byte) error

func (*ResponseEcho) XXX_DiscardUnknown 

func (m *ResponseEcho) XXX_DiscardUnknown()

func (*ResponseEcho) XXX_Marshal 

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

func (*ResponseEcho) XXX_Merge 

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

func (*ResponseEcho) XXX_Size 

func (m *ResponseEcho) XXX_Size() int

func (*ResponseEcho) XXX_Unmarshal 

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

type ResponseException 

type ResponseException struct {
	Error string `protobuf:"bytes,1,opt,name=error,proto3" json:"error,omitempty"`
}

nondeterministic

func (*ResponseException) Descriptor 

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

func (*ResponseException) GetError 

func (m *ResponseException) GetError() string

func (*ResponseException) Marshal 

func (m *ResponseException) Marshal() (dAtA []byte, err error)

func (*ResponseException) MarshalTo 

func (m *ResponseException) MarshalTo(dAtA []byte) (int, error)

func (*ResponseException) MarshalToSizedBuffer 

func (m *ResponseException) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseException) ProtoMessage 

func (*ResponseException) ProtoMessage()

func (*ResponseException) Reset 

func (m *ResponseException) Reset()

func (*ResponseException) Size 

func (m *ResponseException) Size() (n int)

func (*ResponseException) String 

func (m *ResponseException) String() string

func (*ResponseException) Unmarshal 

func (m *ResponseException) Unmarshal(dAtA []byte) error

func (*ResponseException) XXX_DiscardUnknown 

func (m *ResponseException) XXX_DiscardUnknown()

func (*ResponseException) XXX_Marshal 

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

func (*ResponseException) XXX_Merge 

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

func (*ResponseException) XXX_Size 

func (m *ResponseException) XXX_Size() int

func (*ResponseException) XXX_Unmarshal 

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

type ResponseFlush 

type ResponseFlush struct {
}

func (*ResponseFlush) Descriptor 

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

func (*ResponseFlush) Marshal 

func (m *ResponseFlush) Marshal() (dAtA []byte, err error)

func (*ResponseFlush) MarshalTo 

func (m *ResponseFlush) MarshalTo(dAtA []byte) (int, error)

func (*ResponseFlush) MarshalToSizedBuffer 

func (m *ResponseFlush) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseFlush) ProtoMessage 

func (*ResponseFlush) ProtoMessage()

func (*ResponseFlush) Reset 

func (m *ResponseFlush) Reset()

func (*ResponseFlush) Size 

func (m *ResponseFlush) Size() (n int)

func (*ResponseFlush) String 

func (m *ResponseFlush) String() string

func (*ResponseFlush) Unmarshal 

func (m *ResponseFlush) Unmarshal(dAtA []byte) error

func (*ResponseFlush) XXX_DiscardUnknown 

func (m *ResponseFlush) XXX_DiscardUnknown()

func (*ResponseFlush) XXX_Marshal 

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

func (*ResponseFlush) XXX_Merge 

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

func (*ResponseFlush) XXX_Size 

func (m *ResponseFlush) XXX_Size() int

func (*ResponseFlush) XXX_Unmarshal 

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

type ResponseInfo 

type ResponseInfo struct {
	Data             string `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Version          string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	AppVersion       uint64 `protobuf:"varint,3,opt,name=app_version,json=appVersion,proto3" json:"app_version,omitempty"`
	LastBlockHeight  int64  `protobuf:"varint,4,opt,name=last_block_height,json=lastBlockHeight,proto3" json:"last_block_height,omitempty"`
	LastBlockAppHash []byte `protobuf:"bytes,5,opt,name=last_block_app_hash,json=lastBlockAppHash,proto3" json:"last_block_app_hash,omitempty"`
}

func (*ResponseInfo) Descriptor 

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

func (*ResponseInfo) GetAppVersion 

func (m *ResponseInfo) GetAppVersion() uint64

func (*ResponseInfo) GetData 

func (m *ResponseInfo) GetData() string

func (*ResponseInfo) GetLastBlockAppHash 

func (m *ResponseInfo) GetLastBlockAppHash() []byte

func (*ResponseInfo) GetLastBlockHeight 

func (m *ResponseInfo) GetLastBlockHeight() int64

func (*ResponseInfo) GetVersion 

func (m *ResponseInfo) GetVersion() string

func (*ResponseInfo) Marshal 

func (m *ResponseInfo) Marshal() (dAtA []byte, err error)

func (*ResponseInfo) MarshalTo 

func (m *ResponseInfo) MarshalTo(dAtA []byte) (int, error)

func (*ResponseInfo) MarshalToSizedBuffer 

func (m *ResponseInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseInfo) ProtoMessage 

func (*ResponseInfo) ProtoMessage()

func (*ResponseInfo) Reset 

func (m *ResponseInfo) Reset()

func (*ResponseInfo) Size 

func (m *ResponseInfo) Size() (n int)

func (*ResponseInfo) String 

func (m *ResponseInfo) String() string

func (*ResponseInfo) Unmarshal 

func (m *ResponseInfo) Unmarshal(dAtA []byte) error

func (*ResponseInfo) XXX_DiscardUnknown 

func (m *ResponseInfo) XXX_DiscardUnknown()

func (*ResponseInfo) XXX_Marshal 

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

func (*ResponseInfo) XXX_Merge 

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

func (*ResponseInfo) XXX_Size 

func (m *ResponseInfo) XXX_Size() int

func (*ResponseInfo) XXX_Unmarshal 

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

type ResponseProcessDVSRequest 

type ResponseProcessDVSRequest struct {
	Code           uint32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Data           []byte  `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Log            string  `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
	Info           string  `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	Events         []Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	Codespace      string  `protobuf:"bytes,6,opt,name=codespace,proto3" json:"codespace,omitempty"`
	Response       []byte  `protobuf:"bytes,7,opt,name=response,proto3" json:"response,omitempty"`
	ResponseDigest []byte  `protobuf:"bytes,8,opt,name=response_digest,json=responseDigest,proto3" json:"response_digest,omitempty"`
}

func (*ResponseProcessDVSRequest) Descriptor 

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

func (*ResponseProcessDVSRequest) GetCode 

func (m *ResponseProcessDVSRequest) GetCode() uint32

func (*ResponseProcessDVSRequest) GetCodespace 

func (m *ResponseProcessDVSRequest) GetCodespace() string

func (*ResponseProcessDVSRequest) GetData 

func (m *ResponseProcessDVSRequest) GetData() []byte

func (*ResponseProcessDVSRequest) GetEvents 

func (m *ResponseProcessDVSRequest) GetEvents() []Event

func (*ResponseProcessDVSRequest) GetInfo 

func (m *ResponseProcessDVSRequest) GetInfo() string

func (*ResponseProcessDVSRequest) GetLog 

func (m *ResponseProcessDVSRequest) GetLog() string

func (*ResponseProcessDVSRequest) GetResponse 

func (m *ResponseProcessDVSRequest) GetResponse() []byte

func (*ResponseProcessDVSRequest) GetResponseDigest 

func (m *ResponseProcessDVSRequest) GetResponseDigest() []byte

func (*ResponseProcessDVSRequest) Marshal 

func (m *ResponseProcessDVSRequest) Marshal() (dAtA []byte, err error)

func (*ResponseProcessDVSRequest) MarshalTo 

func (m *ResponseProcessDVSRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResponseProcessDVSRequest) MarshalToSizedBuffer 

func (m *ResponseProcessDVSRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseProcessDVSRequest) ProtoMessage 

func (*ResponseProcessDVSRequest) ProtoMessage()

func (*ResponseProcessDVSRequest) Reset 

func (m *ResponseProcessDVSRequest) Reset()

func (*ResponseProcessDVSRequest) Size 

func (m *ResponseProcessDVSRequest) Size() (n int)

func (*ResponseProcessDVSRequest) String 

func (m *ResponseProcessDVSRequest) String() string

func (*ResponseProcessDVSRequest) Unmarshal 

func (m *ResponseProcessDVSRequest) Unmarshal(dAtA []byte) error

func (*ResponseProcessDVSRequest) XXX_DiscardUnknown 

func (m *ResponseProcessDVSRequest) XXX_DiscardUnknown()

func (*ResponseProcessDVSRequest) XXX_Marshal 

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

func (*ResponseProcessDVSRequest) XXX_Merge 

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

func (*ResponseProcessDVSRequest) XXX_Size 

func (m *ResponseProcessDVSRequest) XXX_Size() int

func (*ResponseProcessDVSRequest) XXX_Unmarshal 

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

type ResponseProcessDVSResponse 

type ResponseProcessDVSResponse struct {
	Code      uint32  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Data      []byte  `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Log       string  `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
	Info      string  `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	Events    []Event `protobuf:"bytes,5,rep,name=events,proto3" json:"events,omitempty"`
	Codespace string  `protobuf:"bytes,6,opt,name=codespace,proto3" json:"codespace,omitempty"`
}

func (*ResponseProcessDVSResponse) Descriptor 

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

func (*ResponseProcessDVSResponse) GetCode 

func (m *ResponseProcessDVSResponse) GetCode() uint32

func (*ResponseProcessDVSResponse) GetCodespace 

func (m *ResponseProcessDVSResponse) GetCodespace() string

func (*ResponseProcessDVSResponse) GetData 

func (m *ResponseProcessDVSResponse) GetData() []byte

func (*ResponseProcessDVSResponse) GetEvents 

func (m *ResponseProcessDVSResponse) GetEvents() []Event

func (*ResponseProcessDVSResponse) GetInfo 

func (m *ResponseProcessDVSResponse) GetInfo() string

func (*ResponseProcessDVSResponse) GetLog 

func (m *ResponseProcessDVSResponse) GetLog() string

func (*ResponseProcessDVSResponse) Marshal 

func (m *ResponseProcessDVSResponse) Marshal() (dAtA []byte, err error)

func (*ResponseProcessDVSResponse) MarshalTo 

func (m *ResponseProcessDVSResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResponseProcessDVSResponse) MarshalToSizedBuffer 

func (m *ResponseProcessDVSResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseProcessDVSResponse) ProtoMessage 

func (*ResponseProcessDVSResponse) ProtoMessage()

func (*ResponseProcessDVSResponse) Reset 

func (m *ResponseProcessDVSResponse) Reset()

func (*ResponseProcessDVSResponse) Size 

func (m *ResponseProcessDVSResponse) Size() (n int)

func (*ResponseProcessDVSResponse) String 

func (m *ResponseProcessDVSResponse) String() string

func (*ResponseProcessDVSResponse) Unmarshal 

func (m *ResponseProcessDVSResponse) Unmarshal(dAtA []byte) error

func (*ResponseProcessDVSResponse) XXX_DiscardUnknown 

func (m *ResponseProcessDVSResponse) XXX_DiscardUnknown()

func (*ResponseProcessDVSResponse) XXX_Marshal 

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

func (*ResponseProcessDVSResponse) XXX_Merge 

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

func (*ResponseProcessDVSResponse) XXX_Size 

func (m *ResponseProcessDVSResponse) XXX_Size() int

func (*ResponseProcessDVSResponse) XXX_Unmarshal 

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

type ResponseQuery 

type ResponseQuery struct {
	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// bytes data = 2; // use "value" instead.
	Log       string           `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
	Info      string           `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	Index     int64            `protobuf:"varint,5,opt,name=index,proto3" json:"index,omitempty"`
	Key       []byte           `protobuf:"bytes,6,opt,name=key,proto3" json:"key,omitempty"`
	Value     []byte           `protobuf:"bytes,7,opt,name=value,proto3" json:"value,omitempty"`
	ProofOps  *crypto.ProofOps `protobuf:"bytes,8,opt,name=proof_ops,json=proofOps,proto3" json:"proof_ops,omitempty"`
	Height    int64            `protobuf:"varint,9,opt,name=height,proto3" json:"height,omitempty"`
	Codespace string           `protobuf:"bytes,10,opt,name=codespace,proto3" json:"codespace,omitempty"`
}

func (*ResponseQuery) Descriptor 

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

func (*ResponseQuery) GetCode 

func (m *ResponseQuery) GetCode() uint32

func (*ResponseQuery) GetCodespace 

func (m *ResponseQuery) GetCodespace() string

func (*ResponseQuery) GetHeight 

func (m *ResponseQuery) GetHeight() int64

func (*ResponseQuery) GetIndex 

func (m *ResponseQuery) GetIndex() int64

func (*ResponseQuery) GetInfo 

func (m *ResponseQuery) GetInfo() string

func (*ResponseQuery) GetKey 

func (m *ResponseQuery) GetKey() []byte

func (*ResponseQuery) GetLog 

func (m *ResponseQuery) GetLog() string

func (*ResponseQuery) GetProofOps 

func (m *ResponseQuery) GetProofOps() *crypto.ProofOps

func (*ResponseQuery) GetValue 

func (m *ResponseQuery) GetValue() []byte

func (ResponseQuery) IsErr 

func (r ResponseQuery) IsErr() bool

IsErr returns true if Code is something other than OK.

func (ResponseQuery) IsOK 

func (r ResponseQuery) IsOK() bool

IsOK returns true if Code is OK.

func (*ResponseQuery) Marshal 

func (m *ResponseQuery) Marshal() (dAtA []byte, err error)

func (*ResponseQuery) MarshalJSON 

func (r *ResponseQuery) MarshalJSON() ([]byte, error)

func (*ResponseQuery) MarshalTo 

func (m *ResponseQuery) MarshalTo(dAtA []byte) (int, error)

func (*ResponseQuery) MarshalToSizedBuffer 

func (m *ResponseQuery) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResponseQuery) ProtoMessage 

func (*ResponseQuery) ProtoMessage()

func (*ResponseQuery) Reset 

func (m *ResponseQuery) Reset()

func (*ResponseQuery) Size 

func (m *ResponseQuery) Size() (n int)

func (*ResponseQuery) String 

func (m *ResponseQuery) String() string

func (*ResponseQuery) Unmarshal 

func (m *ResponseQuery) Unmarshal(dAtA []byte) error

func (*ResponseQuery) UnmarshalJSON 

func (r *ResponseQuery) UnmarshalJSON(b []byte) error

func (*ResponseQuery) XXX_DiscardUnknown 

func (m *ResponseQuery) XXX_DiscardUnknown()

func (*ResponseQuery) XXX_Marshal 

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

func (*ResponseQuery) XXX_Merge 

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

func (*ResponseQuery) XXX_Size 

func (m *ResponseQuery) XXX_Size() int

func (*ResponseQuery) XXX_Unmarshal 

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

type Response_Echo 

type Response_Echo struct {
	Echo *ResponseEcho `protobuf:"bytes,3,opt,name=echo,proto3,oneof" json:"echo,omitempty"`
}

func (*Response_Echo) MarshalTo 

func (m *Response_Echo) MarshalTo(dAtA []byte) (int, error)

func (*Response_Echo) MarshalToSizedBuffer 

func (m *Response_Echo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_Echo) Size 

func (m *Response_Echo) Size() (n int)

type Response_Exception 

type Response_Exception struct {
	Exception *ResponseException `protobuf:"bytes,1,opt,name=exception,proto3,oneof" json:"exception,omitempty"`
}

func (*Response_Exception) MarshalTo 

func (m *Response_Exception) MarshalTo(dAtA []byte) (int, error)

func (*Response_Exception) MarshalToSizedBuffer 

func (m *Response_Exception) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_Exception) Size 

func (m *Response_Exception) Size() (n int)

type Response_Flush 

type Response_Flush struct {
	Flush *ResponseFlush `protobuf:"bytes,2,opt,name=flush,proto3,oneof" json:"flush,omitempty"`
}

func (*Response_Flush) MarshalTo 

func (m *Response_Flush) MarshalTo(dAtA []byte) (int, error)

func (*Response_Flush) MarshalToSizedBuffer 

func (m *Response_Flush) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_Flush) Size 

func (m *Response_Flush) Size() (n int)

type Response_Info 

type Response_Info struct {
	Info *ResponseInfo `protobuf:"bytes,4,opt,name=info,proto3,oneof" json:"info,omitempty"`
}

func (*Response_Info) MarshalTo 

func (m *Response_Info) MarshalTo(dAtA []byte) (int, error)

func (*Response_Info) MarshalToSizedBuffer 

func (m *Response_Info) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_Info) Size 

func (m *Response_Info) Size() (n int)

type Response_ProcessDvsRequest 

type Response_ProcessDvsRequest struct {
	ProcessDvsRequest *ResponseProcessDVSRequest `protobuf:"bytes,6,opt,name=process_dvs_request,json=processDvsRequest,proto3,oneof" json:"process_dvs_request,omitempty"`
}

func (*Response_ProcessDvsRequest) MarshalTo 

func (m *Response_ProcessDvsRequest) MarshalTo(dAtA []byte) (int, error)

func (*Response_ProcessDvsRequest) MarshalToSizedBuffer 

func (m *Response_ProcessDvsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_ProcessDvsRequest) Size 

func (m *Response_ProcessDvsRequest) Size() (n int)

type Response_ProcessDvsResponse 

type Response_ProcessDvsResponse struct {
	ProcessDvsResponse *ResponseProcessDVSResponse `protobuf:"bytes,7,opt,name=process_dvs_response,json=processDvsResponse,proto3,oneof" json:"process_dvs_response,omitempty"`
}

func (*Response_ProcessDvsResponse) MarshalTo 

func (m *Response_ProcessDvsResponse) MarshalTo(dAtA []byte) (int, error)

func (*Response_ProcessDvsResponse) MarshalToSizedBuffer 

func (m *Response_ProcessDvsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_ProcessDvsResponse) Size 

func (m *Response_ProcessDvsResponse) Size() (n int)

type Response_Query 

type Response_Query struct {
	Query *ResponseQuery `protobuf:"bytes,5,opt,name=query,proto3,oneof" json:"query,omitempty"`
}

func (*Response_Query) MarshalTo 

func (m *Response_Query) MarshalTo(dAtA []byte) (int, error)

func (*Response_Query) MarshalToSizedBuffer 

func (m *Response_Query) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Response_Query) Size 

func (m *Response_Query) Size() (n int)

type UnimplementedAVSIServer 

type UnimplementedAVSIServer struct {
}

UnimplementedAVSIServer can be embedded to have forward compatible implementations.

func (*UnimplementedAVSIServer) Echo 

func (*UnimplementedAVSIServer) Echo(ctx context.Context, req *RequestEcho) (*ResponseEcho, error)

func (*UnimplementedAVSIServer) Flush 

func (*UnimplementedAVSIServer) Flush(ctx context.Context, req *RequestFlush) (*ResponseFlush, error)

func (*UnimplementedAVSIServer) Info 

func (*UnimplementedAVSIServer) Info(ctx context.Context, req *RequestInfo) (*ResponseInfo, error)

func (*UnimplementedAVSIServer) ProcessDVSRequest 

func (*UnimplementedAVSIServer) ProcessDVSRequest(ctx context.Context, req *RequestProcessDVSRequest) (*ResponseProcessDVSRequest, error)

func (*UnimplementedAVSIServer) ProcessDVSResponse 

func (*UnimplementedAVSIServer) ProcessDVSResponse(ctx context.Context, req *RequestProcessDVSResponse) (*ResponseProcessDVSResponse, error)

func (*UnimplementedAVSIServer) Query 

func (*UnimplementedAVSIServer) Query(ctx context.Context, req *RequestQuery) (*ResponseQuery, 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.