pb

package
v0.0.0-...-735feb9 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCalvin = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCalvin   = fmt.Errorf("proto: integer overflow")
)
View Source 
var MessageType_name = map[int32]string{
	0: "TRANSACTION",
	1: "LOW_ISO_READ",
}
View Source 
var MessageType_value = map[string]int32{
	"TRANSACTION":  0,
	"LOW_ISO_READ": 1,
}

Functions

func RegisterCalvinServer 

func RegisterCalvinServer(s *grpc.Server, srv CalvinServer)

func RegisterLowIsolationReadServer 

func RegisterLowIsolationReadServer(s *grpc.Server, srv LowIsolationReadServer)

func RegisterRaftTransportServer 

func RegisterRaftTransportServer(s *grpc.Server, srv RaftTransportServer)

func RegisterRemoteReadServer 

func RegisterRemoteReadServer(s *grpc.Server, srv RemoteReadServer)

Types

type BaseMessage 

type BaseMessage struct {
	Type                 MessageType `protobuf:"varint,1,opt,name=Type,proto3,enum=pb.MessageType" json:"Type,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

EXPERIMENTAL

func (*BaseMessage) Descriptor 

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

func (*BaseMessage) Marshal 

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

func (*BaseMessage) MarshalTo 

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

func (*BaseMessage) ProtoMessage 

func (*BaseMessage) ProtoMessage()

func (*BaseMessage) Reset 

func (m *BaseMessage) Reset()

func (*BaseMessage) Size 

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

func (*BaseMessage) String 

func (m *BaseMessage) String() string

func (*BaseMessage) Unmarshal 

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

func (*BaseMessage) XXX_DiscardUnknown 

func (m *BaseMessage) XXX_DiscardUnknown()

func (*BaseMessage) XXX_Marshal 

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

func (*BaseMessage) XXX_Merge 

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

func (*BaseMessage) XXX_Size 

func (m *BaseMessage) XXX_Size() int

func (*BaseMessage) XXX_Unmarshal 

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

type CalvinClient 

type CalvinClient interface {
	SubmitTransaction(ctx context.Context, in *SubmitTransactionRequest, opts ...grpc.CallOption) (*SubmitTransactionResponse, error)
}

CalvinClient is the client API for Calvin service.

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

func NewCalvinClient 

func NewCalvinClient(cc *grpc.ClientConn) CalvinClient

type CalvinServer 

type CalvinServer interface {
	SubmitTransaction(context.Context, *SubmitTransactionRequest) (*SubmitTransactionResponse, error)
}

CalvinServer is the server API for Calvin service.

type Id128 

type Id128 struct {
	Upper                uint64   `protobuf:"varint,1,opt,name=Upper,proto3" json:"Upper,omitempty"`
	Lower                uint64   `protobuf:"varint,2,opt,name=Lower,proto3" json:"Lower,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Id128) Compare 

func (this *Id128) Compare(that interface{}) int

func (*Id128) Descriptor 

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

func (*Id128) Equal 

func (this *Id128) Equal(that interface{}) bool

func (*Id128) Marshal 

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

func (*Id128) MarshalTo 

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

func (*Id128) ProtoMessage 

func (*Id128) ProtoMessage()

func (*Id128) Reset 

func (m *Id128) Reset()

func (*Id128) Size 

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

func (*Id128) String 

func (m *Id128) String() string

func (*Id128) Unmarshal 

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

func (*Id128) XXX_DiscardUnknown 

func (m *Id128) XXX_DiscardUnknown()

func (*Id128) XXX_Marshal 

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

func (*Id128) XXX_Merge 

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

func (*Id128) XXX_Size 

func (m *Id128) XXX_Size() int

func (*Id128) XXX_Unmarshal 

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

type LowIsoRead 

type LowIsoRead struct {
	Type                     MessageType               `protobuf:"varint,1,opt,name=Type,proto3,enum=pb.MessageType" json:"Type,omitempty"`
	LowIsolationReadResponse *LowIsolationReadResponse `protobuf:"bytes,2,opt,name=LowIsolationReadResponse,proto3" json:"LowIsolationReadResponse,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                  `json:"-"`
	XXX_unrecognized         []byte                    `json:"-"`
	XXX_sizecache            int32                     `json:"-"`
}

func (*LowIsoRead) Descriptor 

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

func (*LowIsoRead) Marshal 

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

func (*LowIsoRead) MarshalTo 

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

func (*LowIsoRead) ProtoMessage 

func (*LowIsoRead) ProtoMessage()

func (*LowIsoRead) Reset 

func (m *LowIsoRead) Reset()

func (*LowIsoRead) Size 

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

func (*LowIsoRead) String 

func (m *LowIsoRead) String() string

func (*LowIsoRead) Unmarshal 

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

func (*LowIsoRead) XXX_DiscardUnknown 

func (m *LowIsoRead) XXX_DiscardUnknown()

func (*LowIsoRead) XXX_Marshal 

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

func (*LowIsoRead) XXX_Merge 

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

func (*LowIsoRead) XXX_Size 

func (m *LowIsoRead) XXX_Size() int

func (*LowIsoRead) XXX_Unmarshal 

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

type LowIsolationReadClient 

type LowIsolationReadClient interface {
	LowIsolationRead(ctx context.Context, in *LowIsolationReadRequest, opts ...grpc.CallOption) (*LowIsolationReadResponse, error)
}

LowIsolationReadClient is the client API for LowIsolationRead service.

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

func NewLowIsolationReadClient 

func NewLowIsolationReadClient(cc *grpc.ClientConn) LowIsolationReadClient

type LowIsolationReadRequest 

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

func (*LowIsolationReadRequest) Descriptor 

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

func (*LowIsolationReadRequest) Marshal 

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

func (*LowIsolationReadRequest) MarshalTo 

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

func (*LowIsolationReadRequest) ProtoMessage 

func (*LowIsolationReadRequest) ProtoMessage()

func (*LowIsolationReadRequest) Reset 

func (m *LowIsolationReadRequest) Reset()

func (*LowIsolationReadRequest) Size 

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

func (*LowIsolationReadRequest) String 

func (m *LowIsolationReadRequest) String() string

func (*LowIsolationReadRequest) Unmarshal 

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

func (*LowIsolationReadRequest) XXX_DiscardUnknown 

func (m *LowIsolationReadRequest) XXX_DiscardUnknown()

func (*LowIsolationReadRequest) XXX_Marshal 

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

func (*LowIsolationReadRequest) XXX_Merge 

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

func (*LowIsolationReadRequest) XXX_Size 

func (m *LowIsolationReadRequest) XXX_Size() int

func (*LowIsolationReadRequest) XXX_Unmarshal 

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

type LowIsolationReadResponse 

type LowIsolationReadResponse struct {
	Keys                 [][]byte `protobuf:"bytes,1,rep,name=Keys,proto3" json:"Keys,omitempty"`
	Values               [][]byte `protobuf:"bytes,2,rep,name=Values,proto3" json:"Values,omitempty"`
	Term                 uint64   `protobuf:"varint,3,opt,name=Term,proto3" json:"Term,omitempty"`
	Index                uint64   `protobuf:"varint,4,opt,name=Index,proto3" json:"Index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LowIsolationReadResponse) Compare 

func (this *LowIsolationReadResponse) Compare(that interface{}) int

func (*LowIsolationReadResponse) Descriptor 

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

func (*LowIsolationReadResponse) Equal 

func (this *LowIsolationReadResponse) Equal(that interface{}) bool

func (*LowIsolationReadResponse) Marshal 

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

func (*LowIsolationReadResponse) MarshalTo 

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

func (*LowIsolationReadResponse) ProtoMessage 

func (*LowIsolationReadResponse) ProtoMessage()

func (*LowIsolationReadResponse) Reset 

func (m *LowIsolationReadResponse) Reset()

func (*LowIsolationReadResponse) Size 

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

func (*LowIsolationReadResponse) String 

func (m *LowIsolationReadResponse) String() string

func (*LowIsolationReadResponse) Unmarshal 

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

func (*LowIsolationReadResponse) XXX_DiscardUnknown 

func (m *LowIsolationReadResponse) XXX_DiscardUnknown()

func (*LowIsolationReadResponse) XXX_Marshal 

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

func (*LowIsolationReadResponse) XXX_Merge 

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

func (*LowIsolationReadResponse) XXX_Size 

func (m *LowIsolationReadResponse) XXX_Size() int

func (*LowIsolationReadResponse) XXX_Unmarshal 

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

type LowIsolationReadServer 

type LowIsolationReadServer interface {
	LowIsolationRead(context.Context, *LowIsolationReadRequest) (*LowIsolationReadResponse, error)
}

LowIsolationReadServer is the server API for LowIsolationRead service.

type MessageType 

type MessageType int32
const (
	TRANSACTION  MessageType = 0
	LOW_ISO_READ MessageType = 1
)

func (MessageType) EnumDescriptor 

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

func (MessageType) String 

func (x MessageType) String() string

type PartitionedSnapshot 

type PartitionedSnapshot struct {
	PartitionIDs         []uint64 `protobuf:"varint,1,rep,packed,name=PartitionIDs,proto3" json:"PartitionIDs,omitempty"`
	Snapshots            [][]byte `protobuf:"bytes,2,rep,name=Snapshots,proto3" json:"Snapshots,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

This is used by the implmentor of the data store! Be mindful of that.

func (*PartitionedSnapshot) Descriptor 

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

func (*PartitionedSnapshot) Marshal 

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

func (*PartitionedSnapshot) MarshalTo 

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

func (*PartitionedSnapshot) ProtoMessage 

func (*PartitionedSnapshot) ProtoMessage()

func (*PartitionedSnapshot) Reset 

func (m *PartitionedSnapshot) Reset()

func (*PartitionedSnapshot) Size 

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

func (*PartitionedSnapshot) String 

func (m *PartitionedSnapshot) String() string

func (*PartitionedSnapshot) Unmarshal 

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

func (*PartitionedSnapshot) XXX_DiscardUnknown 

func (m *PartitionedSnapshot) XXX_DiscardUnknown()

func (*PartitionedSnapshot) XXX_Marshal 

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

func (*PartitionedSnapshot) XXX_Merge 

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

func (*PartitionedSnapshot) XXX_Size 

func (m *PartitionedSnapshot) XXX_Size() int

func (*PartitionedSnapshot) XXX_Unmarshal 

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

type RaftPeer 

type RaftPeer struct {
	RaftNodeId           uint64   `protobuf:"varint,1,opt,name=RaftNodeId,proto3" json:"RaftNodeId,omitempty"`
	PeerAddress          string   `protobuf:"bytes,2,opt,name=PeerAddress,proto3" json:"PeerAddress,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RaftPeer) Descriptor 

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

func (*RaftPeer) Marshal 

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

func (*RaftPeer) MarshalTo 

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

func (*RaftPeer) ProtoMessage 

func (*RaftPeer) ProtoMessage()

func (*RaftPeer) Reset 

func (m *RaftPeer) Reset()

func (*RaftPeer) Size 

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

func (*RaftPeer) String 

func (m *RaftPeer) String() string

func (*RaftPeer) Unmarshal 

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

func (*RaftPeer) XXX_DiscardUnknown 

func (m *RaftPeer) XXX_DiscardUnknown()

func (*RaftPeer) XXX_Marshal 

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

func (*RaftPeer) XXX_Merge 

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

func (*RaftPeer) XXX_Size 

func (m *RaftPeer) XXX_Size() int

func (*RaftPeer) XXX_Unmarshal 

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

type RaftTransportClient 

type RaftTransportClient interface {
	StepStream(ctx context.Context, opts ...grpc.CallOption) (RaftTransport_StepStreamClient, error)
}

RaftTransportClient is the client API for RaftTransport service.

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

func NewRaftTransportClient 

func NewRaftTransportClient(cc *grpc.ClientConn) RaftTransportClient

type RaftTransportServer 

type RaftTransportServer interface {
	StepStream(RaftTransport_StepStreamServer) error
}

RaftTransportServer is the server API for RaftTransport service.

type RaftTransport_StepStreamClient 

type RaftTransport_StepStreamClient interface {
	Send(*StepRequest) error
	Recv() (*StepResponse, error)
	grpc.ClientStream
}

type RaftTransport_StepStreamServer 

type RaftTransport_StepStreamServer interface {
	Send(*StepResponse) error
	Recv() (*StepRequest, error)
	grpc.ServerStream
}

type RemoteReadClient 

type RemoteReadClient interface {
	RemoteRead(ctx context.Context, in *RemoteReadRequest, opts ...grpc.CallOption) (*RemoteReadResponse, error)
}

RemoteReadClient is the client API for RemoteRead service.

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

func NewRemoteReadClient 

func NewRemoteReadClient(cc *grpc.ClientConn) RemoteReadClient

type RemoteReadRequest 

type RemoteReadRequest struct {
	TxnId                *Id128   `protobuf:"bytes,1,opt,name=TxnId,proto3" json:"TxnId,omitempty"`
	Keys                 [][]byte `protobuf:"bytes,2,rep,name=Keys,proto3" json:"Keys,omitempty"`
	Values               [][]byte `protobuf:"bytes,3,rep,name=Values,proto3" json:"Values,omitempty"`
	TotalNumLocks        uint32   `protobuf:"varint,4,opt,name=TotalNumLocks,proto3" json:"TotalNumLocks,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoteReadRequest) Descriptor 

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

func (*RemoteReadRequest) Marshal 

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

func (*RemoteReadRequest) MarshalTo 

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

func (*RemoteReadRequest) ProtoMessage 

func (*RemoteReadRequest) ProtoMessage()

func (*RemoteReadRequest) Reset 

func (m *RemoteReadRequest) Reset()

func (*RemoteReadRequest) Size 

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

func (*RemoteReadRequest) String 

func (m *RemoteReadRequest) String() string

func (*RemoteReadRequest) Unmarshal 

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

func (*RemoteReadRequest) XXX_DiscardUnknown 

func (m *RemoteReadRequest) XXX_DiscardUnknown()

func (*RemoteReadRequest) XXX_Marshal 

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

func (*RemoteReadRequest) XXX_Merge 

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

func (*RemoteReadRequest) XXX_Size 

func (m *RemoteReadRequest) XXX_Size() int

func (*RemoteReadRequest) XXX_Unmarshal 

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

type RemoteReadResponse 

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

func (*RemoteReadResponse) Descriptor 

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

func (*RemoteReadResponse) Marshal 

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

func (*RemoteReadResponse) MarshalTo 

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

func (*RemoteReadResponse) ProtoMessage 

func (*RemoteReadResponse) ProtoMessage()

func (*RemoteReadResponse) Reset 

func (m *RemoteReadResponse) Reset()

func (*RemoteReadResponse) Size 

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

func (*RemoteReadResponse) String 

func (m *RemoteReadResponse) String() string

func (*RemoteReadResponse) Unmarshal 

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

func (*RemoteReadResponse) XXX_DiscardUnknown 

func (m *RemoteReadResponse) XXX_DiscardUnknown()

func (*RemoteReadResponse) XXX_Marshal 

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

func (*RemoteReadResponse) XXX_Merge 

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

func (*RemoteReadResponse) XXX_Size 

func (m *RemoteReadResponse) XXX_Size() int

func (*RemoteReadResponse) XXX_Unmarshal 

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

type RemoteReadServer 

type RemoteReadServer interface {
	RemoteRead(context.Context, *RemoteReadRequest) (*RemoteReadResponse, error)
}

RemoteReadServer is the server API for RemoteRead service.

type SimpleSetterArg 

type SimpleSetterArg struct {
	Key                  []byte   `protobuf:"bytes,1,opt,name=Key,proto3" json:"Key,omitempty"`
	Value                []byte   `protobuf:"bytes,2,opt,name=Value,proto3" json:"Value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SimpleSetterArg) Descriptor 

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

func (*SimpleSetterArg) Marshal 

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

func (*SimpleSetterArg) MarshalTo 

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

func (*SimpleSetterArg) ProtoMessage 

func (*SimpleSetterArg) ProtoMessage()

func (*SimpleSetterArg) Reset 

func (m *SimpleSetterArg) Reset()

func (*SimpleSetterArg) Size 

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

func (*SimpleSetterArg) String 

func (m *SimpleSetterArg) String() string

func (*SimpleSetterArg) Unmarshal 

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

func (*SimpleSetterArg) XXX_DiscardUnknown 

func (m *SimpleSetterArg) XXX_DiscardUnknown()

func (*SimpleSetterArg) XXX_Marshal 

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

func (*SimpleSetterArg) XXX_Merge 

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

func (*SimpleSetterArg) XXX_Size 

func (m *SimpleSetterArg) XXX_Size() int

func (*SimpleSetterArg) XXX_Unmarshal 

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

type StepRequest 

type StepRequest struct {
	RaftNodeId           uint64          `protobuf:"varint,1,opt,name=RaftNodeId,proto3" json:"RaftNodeId,omitempty"`
	Message              *raftpb.Message `protobuf:"bytes,2,opt,name=Message,proto3" json:"Message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*StepRequest) Descriptor 

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

func (*StepRequest) Marshal 

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

func (*StepRequest) MarshalTo 

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

func (*StepRequest) ProtoMessage 

func (*StepRequest) ProtoMessage()

func (*StepRequest) Reset 

func (m *StepRequest) Reset()

func (*StepRequest) Size 

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

func (*StepRequest) String 

func (m *StepRequest) String() string

func (*StepRequest) Unmarshal 

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

func (*StepRequest) XXX_DiscardUnknown 

func (m *StepRequest) XXX_DiscardUnknown()

func (*StepRequest) XXX_Marshal 

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

func (*StepRequest) XXX_Merge 

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

func (*StepRequest) XXX_Size 

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal 

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

type StepResponse 

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

func (*StepResponse) Descriptor 

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

func (*StepResponse) Marshal 

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

func (*StepResponse) MarshalTo 

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

func (*StepResponse) ProtoMessage 

func (*StepResponse) ProtoMessage()

func (*StepResponse) Reset 

func (m *StepResponse) Reset()

func (*StepResponse) Size 

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

func (*StepResponse) String 

func (m *StepResponse) String() string

func (*StepResponse) Unmarshal 

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

func (*StepResponse) XXX_DiscardUnknown 

func (m *StepResponse) XXX_DiscardUnknown()

func (*StepResponse) XXX_Marshal 

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

func (*StepResponse) XXX_Merge 

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

func (*StepResponse) XXX_Size 

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal 

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

type SubmitTransactionRequest 

type SubmitTransactionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubmitTransactionRequest) Descriptor 

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

func (*SubmitTransactionRequest) Marshal 

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

func (*SubmitTransactionRequest) MarshalTo 

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

func (*SubmitTransactionRequest) ProtoMessage 

func (*SubmitTransactionRequest) ProtoMessage()

func (*SubmitTransactionRequest) Reset 

func (m *SubmitTransactionRequest) Reset()

func (*SubmitTransactionRequest) Size 

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

func (*SubmitTransactionRequest) String 

func (m *SubmitTransactionRequest) String() string

func (*SubmitTransactionRequest) Unmarshal 

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

func (*SubmitTransactionRequest) XXX_DiscardUnknown 

func (m *SubmitTransactionRequest) XXX_DiscardUnknown()

func (*SubmitTransactionRequest) XXX_Marshal 

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

func (*SubmitTransactionRequest) XXX_Merge 

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

func (*SubmitTransactionRequest) XXX_Size 

func (m *SubmitTransactionRequest) XXX_Size() int

func (*SubmitTransactionRequest) XXX_Unmarshal 

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

type SubmitTransactionResponse 

type SubmitTransactionResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubmitTransactionResponse) Descriptor 

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

func (*SubmitTransactionResponse) Marshal 

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

func (*SubmitTransactionResponse) MarshalTo 

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

func (*SubmitTransactionResponse) ProtoMessage 

func (*SubmitTransactionResponse) ProtoMessage()

func (*SubmitTransactionResponse) Reset 

func (m *SubmitTransactionResponse) Reset()

func (*SubmitTransactionResponse) Size 

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

func (*SubmitTransactionResponse) String 

func (m *SubmitTransactionResponse) String() string

func (*SubmitTransactionResponse) Unmarshal 

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

func (*SubmitTransactionResponse) XXX_DiscardUnknown 

func (m *SubmitTransactionResponse) XXX_DiscardUnknown()

func (*SubmitTransactionResponse) XXX_Marshal 

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

func (*SubmitTransactionResponse) XXX_Merge 

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

func (*SubmitTransactionResponse) XXX_Size 

func (m *SubmitTransactionResponse) XXX_Size() int

func (*SubmitTransactionResponse) XXX_Unmarshal 

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

type Transaction 

type Transaction struct {
	Type MessageType `protobuf:"varint,1,opt,name=Type,proto3,enum=pb.MessageType" json:"Type,omitempty"`
	Id   *Id128      `protobuf:"bytes,2,opt,name=Id,proto3" json:"Id,omitempty"`
	// keys of the data objects that are being accessed
	ReadSet      [][]byte `protobuf:"bytes,3,rep,name=ReadSet,proto3" json:"ReadSet,omitempty"`
	ReadWriteSet [][]byte `protobuf:"bytes,4,rep,name=ReadWriteSet,proto3" json:"ReadWriteSet,omitempty"`
	// ids of the nodes that are being contacted
	ReaderNodes []uint64 `protobuf:"varint,5,rep,packed,name=ReaderNodes,proto3" json:"ReaderNodes,omitempty"`
	WriterNodes []uint64 `protobuf:"varint,6,rep,packed,name=WriterNodes,proto3" json:"WriterNodes,omitempty"`
	// the stored procedure that's being invoked
	StoredProcedure     string   `protobuf:"bytes,7,opt,name=StoredProcedure,proto3" json:"StoredProcedure,omitempty"`
	StoredProcedureArgs [][]byte `protobuf:"bytes,8,rep,name=StoredProcedureArgs,proto3" json:"StoredProcedureArgs,omitempty"`
	// only true when the transaction is a low isolation read
	// in that case LowIsolationReadResponse is populated by the execution routines
	// a nifty way to get this info from the execution back to the scheduler
	IsLowIsolationRead       bool                      `protobuf:"varint,9,opt,name=IsLowIsolationRead,proto3" json:"IsLowIsolationRead,omitempty"`
	LowIsolationReadResponse *LowIsolationReadResponse `protobuf:"bytes,10,opt,name=LowIsolationReadResponse,proto3" json:"LowIsolationReadResponse,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}                  `json:"-"`
	XXX_unrecognized         []byte                    `json:"-"`
	XXX_sizecache            int32                     `json:"-"`
}

func (*Transaction) AddSimpleSetterArg 

func (m *Transaction) AddSimpleSetterArg(key []byte, value []byte) error

func (*Transaction) Compare 

func (this *Transaction) Compare(that interface{}) int

func (*Transaction) Descriptor 

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

func (*Transaction) Equal 

func (this *Transaction) Equal(that interface{}) bool

func (*Transaction) Marshal 

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

func (*Transaction) MarshalTo 

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

func (*Transaction) ProtoMessage 

func (*Transaction) ProtoMessage()

func (*Transaction) Reset 

func (m *Transaction) Reset()

func (*Transaction) Size 

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

func (*Transaction) String 

func (m *Transaction) String() string

func (*Transaction) Unmarshal 

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

func (*Transaction) XXX_DiscardUnknown 

func (m *Transaction) XXX_DiscardUnknown()

func (*Transaction) XXX_Marshal 

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

func (*Transaction) XXX_Merge 

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

func (*Transaction) XXX_Size 

func (m *Transaction) XXX_Size() int

func (*Transaction) XXX_Unmarshal 

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

type TransactionBatch 

type TransactionBatch struct {
	Transactions         []*Transaction `protobuf:"bytes,1,rep,name=transactions,proto3" json:"transactions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*TransactionBatch) Descriptor 

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

func (*TransactionBatch) Marshal 

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

func (*TransactionBatch) MarshalTo 

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

func (*TransactionBatch) ProtoMessage 

func (*TransactionBatch) ProtoMessage()

func (*TransactionBatch) Reset 

func (m *TransactionBatch) Reset()

func (*TransactionBatch) Size 

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

func (*TransactionBatch) String 

func (m *TransactionBatch) String() string

func (*TransactionBatch) Unmarshal 

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

func (*TransactionBatch) XXX_DiscardUnknown 

func (m *TransactionBatch) XXX_DiscardUnknown()

func (*TransactionBatch) XXX_Marshal 

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

func (*TransactionBatch) XXX_Merge 

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

func (*TransactionBatch) XXX_Size 

func (m *TransactionBatch) XXX_Size() int

func (*TransactionBatch) XXX_Unmarshal 

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