twopcpb

Documentation

Overview

Package twopcpb is a generated protocol buffer package.

It is generated from these files:

2pc.proto

It has these top-level messages:

Message
EmptyMessage
SetRequest

Index

• Variables
• func RegisterClusterServer(s *grpc.Server, srv ClusterServer)
• type ClusterClient
  • func NewClusterClient(cc *grpc.ClientConn) ClusterClient
• type ClusterServer
• type Cluster_ConnectionClient
• type Cluster_ConnectionServer
• type EmptyMessage
  • func (*EmptyMessage) Descriptor() ([]byte, []int)
  • func (*EmptyMessage) ProtoMessage()
  • func (m *EmptyMessage) Reset()
  • func (m *EmptyMessage) String() string
• type Message
  • func (*Message) Descriptor() ([]byte, []int)
  • func (m *Message) GetClientID() uint64
  • func (m *Message) GetMessageType() MessageType
  • func (m *Message) GetPayload() []byte
  • func (m *Message) GetRequestID() uint64
  • func (*Message) ProtoMessage()
  • func (m *Message) Reset()
  • func (m *Message) String() string
• type MessageType
  • func (MessageType) EnumDescriptor() ([]byte, []int)
  • func (x MessageType) String() string
• type SetRequest
  • func (*SetRequest) Descriptor() ([]byte, []int)
  • func (m *SetRequest) GetPayload() []byte
  • func (*SetRequest) ProtoMessage()
  • func (m *SetRequest) Reset()
  • func (m *SetRequest) String() string

Variables

var MessageType_name = map[int32]string{
	0: "VoteRequest",
	1: "VoteCommit",
	2: "VoteAbort",
	3: "GlobalCommit",
	4: "GlobalAbort",
	5: "GlobalRequest",
	6: "ACK",
}

var MessageType_value = map[string]int32{
	"VoteRequest":   0,
	"VoteCommit":    1,
	"VoteAbort":     2,
	"GlobalCommit":  3,
	"GlobalAbort":   4,
	"GlobalRequest": 5,
	"ACK":           6,
}

Functions

func RegisterClusterServer

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

Types

type ClusterClient

type ClusterClient interface {
	Connection(ctx context.Context, opts ...grpc.CallOption) (Cluster_ConnectionClient, error)
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*EmptyMessage, error)
}

func NewClusterClient

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer

type ClusterServer interface {
	Connection(Cluster_ConnectionServer) error
	Set(context.Context, *SetRequest) (*EmptyMessage, error)
}

type Cluster_ConnectionClient

type Cluster_ConnectionClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type Cluster_ConnectionServer

type Cluster_ConnectionServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type EmptyMessage

type EmptyMessage struct {
}

func (*EmptyMessage) Descriptor

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

func (*EmptyMessage) ProtoMessage

func (*EmptyMessage) ProtoMessage()

func (*EmptyMessage) Reset

func (m *EmptyMessage) Reset()

func (*EmptyMessage) String

func (m *EmptyMessage) String() string

type Message

type Message struct {
	ClientID    uint64      `protobuf:"varint,1,opt,name=ClientID" json:"ClientID,omitempty"`
	MessageType MessageType `protobuf:"varint,2,opt,name=messageType,enum=twopcpb.MessageType" json:"messageType,omitempty"`
	RequestID   uint64      `protobuf:"varint,3,opt,name=requestID" json:"requestID,omitempty"`
	// Substantial request
	Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*Message) Descriptor

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

func (*Message) GetClientID

func (m *Message) GetClientID() uint64

func (*Message) GetMessageType

func (m *Message) GetMessageType() MessageType

func (*Message) GetPayload

func (m *Message) GetPayload() []byte

func (*Message) GetRequestID

func (m *Message) GetRequestID() uint64

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) Reset

func (m *Message) Reset()

func (*Message) String

func (m *Message) String() string

type MessageType

type MessageType int32

const (
	MessageType_VoteRequest   MessageType = 0
	MessageType_VoteCommit    MessageType = 1
	MessageType_VoteAbort     MessageType = 2
	MessageType_GlobalCommit  MessageType = 3
	MessageType_GlobalAbort   MessageType = 4
	MessageType_GlobalRequest MessageType = 5
	MessageType_ACK           MessageType = 6
)

func (MessageType) EnumDescriptor

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

func (MessageType) String

func (x MessageType) String() string

type SetRequest

type SetRequest struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
}

func (*SetRequest) Descriptor

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

func (*SetRequest) GetPayload

func (m *SetRequest) GetPayload() []byte

func (*SetRequest) ProtoMessage

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset

func (m *SetRequest) Reset()

func (*SetRequest) String

func (m *SetRequest) String() string