Documentation
¶
Index ¶
- Variables
- func Max(a uint32, b uint32) uint32
- func RegisterAuctionHouseServer(s grpc.ServiceRegistrar, srv AuctionHouseServer)
- type AuctionHouseClient
- type AuctionHouseServer
- type AuctionHouse_OpenConnectionClient
- type AuctionHouse_OpenConnectionServer
- type BidMessage
- func (*BidMessage) Descriptor() ([]byte, []int)deprecated
- func (x *BidMessage) GetAmount() int32
- func (x *BidMessage) GetTimestamp() uint32
- func (x *BidMessage) GetUser() *User
- func (*BidMessage) ProtoMessage()
- func (x *BidMessage) ProtoReflect() protoreflect.Message
- func (x *BidMessage) Reset()
- func (x *BidMessage) String() string
- type BidReply
- type Connect
- type CutOfMessage
- type ElectionPorts
- type LamportClock
- type Message
- type PortIndex
- type PortsAndClocks
- func (*PortsAndClocks) Descriptor() ([]byte, []int)deprecated
- func (x *PortsAndClocks) GetListOfClocks() []uint32
- func (x *PortsAndClocks) GetListOfPorts() []int32
- func (*PortsAndClocks) ProtoMessage()
- func (x *PortsAndClocks) ProtoReflect() protoreflect.Message
- func (x *PortsAndClocks) Reset()
- func (x *PortsAndClocks) String() string
- type ReplicateMessage
- func (*ReplicateMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicateMessage) GetAmount() int32
- func (x *ReplicateMessage) GetTimestamp() uint32
- func (x *ReplicateMessage) GetUser() *User
- func (*ReplicateMessage) ProtoMessage()
- func (x *ReplicateMessage) ProtoReflect() protoreflect.Message
- func (x *ReplicateMessage) Reset()
- func (x *ReplicateMessage) String() string
- type ReplyMessage
- func (*ReplyMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ReplyMessage) GetPort() int32
- func (x *ReplyMessage) GetServerId() int32
- func (x *ReplyMessage) GetTimestamp() int32
- func (*ReplyMessage) ProtoMessage()
- func (x *ReplyMessage) ProtoReflect() protoreflect.Message
- func (x *ReplyMessage) Reset()
- func (x *ReplyMessage) String() string
- type RequestMessage
- func (*RequestMessage) Descriptor() ([]byte, []int)deprecated
- func (x *RequestMessage) GetPort() int32
- func (x *RequestMessage) GetServerId() int32
- func (x *RequestMessage) GetTimestamp() int32
- func (*RequestMessage) ProtoMessage()
- func (x *RequestMessage) ProtoReflect() protoreflect.Message
- func (x *RequestMessage) Reset()
- func (x *RequestMessage) String() string
- type ResultMessage
- func (*ResultMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ResultMessage) GetAmount() int32
- func (x *ResultMessage) GetStillActive() bool
- func (x *ResultMessage) GetTimestamp() uint32
- func (x *ResultMessage) GetUser() *User
- func (*ResultMessage) ProtoMessage()
- func (x *ResultMessage) ProtoReflect() protoreflect.Message
- func (x *ResultMessage) Reset()
- func (x *ResultMessage) String() string
- type TimeMessage
- func (*TimeMessage) Descriptor() ([]byte, []int)deprecated
- func (x *TimeMessage) GetAuctionStart() string
- func (x *TimeMessage) GetDuration() int32
- func (*TimeMessage) ProtoMessage()
- func (x *TimeMessage) ProtoReflect() protoreflect.Message
- func (x *TimeMessage) Reset()
- func (x *TimeMessage) String() string
- type UnimplementedAuctionHouseServer
- func (UnimplementedAuctionHouseServer) AccessCritical(context.Context, *RequestMessage) (*ReplyMessage, error)
- func (UnimplementedAuctionHouseServer) Bid(context.Context, *BidMessage) (*BidReply, error)
- func (UnimplementedAuctionHouseServer) Broadcast(context.Context, *Message) (*Void, error)
- func (UnimplementedAuctionHouseServer) BroadcastNewLeader(context.Context, *ElectionPorts) (*Void, error)
- func (UnimplementedAuctionHouseServer) CloseConnection(context.Context, *Message) (*Void, error)
- func (UnimplementedAuctionHouseServer) CutOfReplicate(context.Context, *CutOfMessage) (*Void, error)
- func (UnimplementedAuctionHouseServer) GetID(context.Context, *Void) (*PortIndex, error)
- func (UnimplementedAuctionHouseServer) OpenConnection(*Connect, AuctionHouse_OpenConnectionServer) error
- func (UnimplementedAuctionHouseServer) PromptTimeAndDuration(context.Context, *Void) (*TimeMessage, error)
- func (UnimplementedAuctionHouseServer) ReceiveReply(context.Context, *ReplyMessage) (*Void, error)
- func (UnimplementedAuctionHouseServer) ReceiveRequest(context.Context, *RequestMessage) (*Void, error)
- func (UnimplementedAuctionHouseServer) RegisterPulse(context.Context, *Message) (*Void, error)
- func (UnimplementedAuctionHouseServer) Replicate(context.Context, *ReplicateMessage) (*BidReply, error)
- func (UnimplementedAuctionHouseServer) Result(context.Context, *Void) (*ResultMessage, error)
- func (UnimplementedAuctionHouseServer) RingElection(context.Context, *PortsAndClocks) (*Void, error)
- func (UnimplementedAuctionHouseServer) SelectNewLeader(context.Context, *Void) (*ElectionPorts, error)
- func (UnimplementedAuctionHouseServer) SetStateReleased(context.Context, *Void) (*Void, error)
- type UnsafeAuctionHouseServer
- type User
- type Void
Constants ¶
This section is empty.
Variables ¶
var AuctionHouse_ServiceDesc = grpc.ServiceDesc{ ServiceName: "Auction.AuctionHouse", HandlerType: (*AuctionHouseServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CloseConnection", Handler: _AuctionHouse_CloseConnection_Handler, }, { MethodName: "Bid", Handler: _AuctionHouse_Bid_Handler, }, { MethodName: "Result", Handler: _AuctionHouse_Result_Handler, }, { MethodName: "Broadcast", Handler: _AuctionHouse_Broadcast_Handler, }, { MethodName: "Replicate", Handler: _AuctionHouse_Replicate_Handler, }, { MethodName: "getID", Handler: _AuctionHouse_GetID_Handler, }, { MethodName: "RegisterPulse", Handler: _AuctionHouse_RegisterPulse_Handler, }, { MethodName: "RingElection", Handler: _AuctionHouse_RingElection_Handler, }, { MethodName: "SelectNewLeader", Handler: _AuctionHouse_SelectNewLeader_Handler, }, { MethodName: "BroadcastNewLeader", Handler: _AuctionHouse_BroadcastNewLeader_Handler, }, { MethodName: "CutOfReplicate", Handler: _AuctionHouse_CutOfReplicate_Handler, }, { MethodName: "PromptTimeAndDuration", Handler: _AuctionHouse_PromptTimeAndDuration_Handler, }, { MethodName: "AccessCritical", Handler: _AuctionHouse_AccessCritical_Handler, }, { MethodName: "ReceiveRequest", Handler: _AuctionHouse_ReceiveRequest_Handler, }, { MethodName: "ReceiveReply", Handler: _AuctionHouse_ReceiveReply_Handler, }, { MethodName: "SetStateReleased", Handler: _AuctionHouse_SetStateReleased_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "OpenConnection", Handler: _AuctionHouse_OpenConnection_Handler, ServerStreams: true, }, }, Metadata: "Auction/auction.proto", }
AuctionHouse_ServiceDesc is the grpc.ServiceDesc for AuctionHouse service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_Auction_auction_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAuctionHouseServer ¶
func RegisterAuctionHouseServer(s grpc.ServiceRegistrar, srv AuctionHouseServer)
Types ¶
type AuctionHouseClient ¶
type AuctionHouseClient interface { OpenConnection(ctx context.Context, in *Connect, opts ...grpc.CallOption) (AuctionHouse_OpenConnectionClient, error) CloseConnection(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Void, error) Bid(ctx context.Context, in *BidMessage, opts ...grpc.CallOption) (*BidReply, error) Result(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ResultMessage, error) Broadcast(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Void, error) Replicate(ctx context.Context, in *ReplicateMessage, opts ...grpc.CallOption) (*BidReply, error) GetID(ctx context.Context, in *Void, opts ...grpc.CallOption) (*PortIndex, error) RegisterPulse(ctx context.Context, in *Message, opts ...grpc.CallOption) (*Void, error) RingElection(ctx context.Context, in *PortsAndClocks, opts ...grpc.CallOption) (*Void, error) SelectNewLeader(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ElectionPorts, error) BroadcastNewLeader(ctx context.Context, in *ElectionPorts, opts ...grpc.CallOption) (*Void, error) CutOfReplicate(ctx context.Context, in *CutOfMessage, opts ...grpc.CallOption) (*Void, error) PromptTimeAndDuration(ctx context.Context, in *Void, opts ...grpc.CallOption) (*TimeMessage, error) //Ricart And Agrawala AccessCritical(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ReplyMessage, error) ReceiveRequest(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*Void, error) ReceiveReply(ctx context.Context, in *ReplyMessage, opts ...grpc.CallOption) (*Void, error) SetStateReleased(ctx context.Context, in *Void, opts ...grpc.CallOption) (*Void, error) }
AuctionHouseClient is the client API for AuctionHouse service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewAuctionHouseClient ¶
func NewAuctionHouseClient(cc grpc.ClientConnInterface) AuctionHouseClient
type AuctionHouseServer ¶
type AuctionHouseServer interface { OpenConnection(*Connect, AuctionHouse_OpenConnectionServer) error CloseConnection(context.Context, *Message) (*Void, error) Bid(context.Context, *BidMessage) (*BidReply, error) Result(context.Context, *Void) (*ResultMessage, error) Broadcast(context.Context, *Message) (*Void, error) Replicate(context.Context, *ReplicateMessage) (*BidReply, error) GetID(context.Context, *Void) (*PortIndex, error) RegisterPulse(context.Context, *Message) (*Void, error) RingElection(context.Context, *PortsAndClocks) (*Void, error) SelectNewLeader(context.Context, *Void) (*ElectionPorts, error) BroadcastNewLeader(context.Context, *ElectionPorts) (*Void, error) CutOfReplicate(context.Context, *CutOfMessage) (*Void, error) PromptTimeAndDuration(context.Context, *Void) (*TimeMessage, error) //Ricart And Agrawala AccessCritical(context.Context, *RequestMessage) (*ReplyMessage, error) ReceiveRequest(context.Context, *RequestMessage) (*Void, error) ReceiveReply(context.Context, *ReplyMessage) (*Void, error) SetStateReleased(context.Context, *Void) (*Void, error) // contains filtered or unexported methods }
AuctionHouseServer is the server API for AuctionHouse service. All implementations must embed UnimplementedAuctionHouseServer for forward compatibility
type AuctionHouse_OpenConnectionClient ¶
type AuctionHouse_OpenConnectionClient interface { Recv() (*Message, error) grpc.ClientStream }
type AuctionHouse_OpenConnectionServer ¶
type AuctionHouse_OpenConnectionServer interface { Send(*Message) error grpc.ServerStream }
type BidMessage ¶
type BidMessage struct { Amount int32 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"` User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Timestamp uint32 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*BidMessage) Descriptor
deprecated
func (*BidMessage) Descriptor() ([]byte, []int)
Deprecated: Use BidMessage.ProtoReflect.Descriptor instead.
func (*BidMessage) GetAmount ¶
func (x *BidMessage) GetAmount() int32
func (*BidMessage) GetTimestamp ¶
func (x *BidMessage) GetTimestamp() uint32
func (*BidMessage) GetUser ¶
func (x *BidMessage) GetUser() *User
func (*BidMessage) ProtoMessage ¶
func (*BidMessage) ProtoMessage()
func (*BidMessage) ProtoReflect ¶
func (x *BidMessage) ProtoReflect() protoreflect.Message
func (*BidMessage) Reset ¶
func (x *BidMessage) Reset()
func (*BidMessage) String ¶
func (x *BidMessage) String() string
type BidReply ¶
type BidReply struct { ReturnType int32 `protobuf:"varint,1,opt,name=returnType,proto3" json:"returnType,omitempty"` Timestamp uint32 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
Returntype = 1 for success, 2 for fail, 3 for exception
func (*BidReply) Descriptor
deprecated
func (*BidReply) GetReturnType ¶
func (*BidReply) GetTimestamp ¶
func (*BidReply) ProtoMessage ¶
func (*BidReply) ProtoMessage()
func (*BidReply) ProtoReflect ¶
func (x *BidReply) ProtoReflect() protoreflect.Message
type Connect ¶
type Connect struct { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Active bool `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"` // contains filtered or unexported fields }
func (*Connect) Descriptor
deprecated
func (*Connect) ProtoMessage ¶
func (*Connect) ProtoMessage()
func (*Connect) ProtoReflect ¶
func (x *Connect) ProtoReflect() protoreflect.Message
type CutOfMessage ¶
type CutOfMessage struct { Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*CutOfMessage) Descriptor
deprecated
func (*CutOfMessage) Descriptor() ([]byte, []int)
Deprecated: Use CutOfMessage.ProtoReflect.Descriptor instead.
func (*CutOfMessage) GetPort ¶
func (x *CutOfMessage) GetPort() int32
func (*CutOfMessage) ProtoMessage ¶
func (*CutOfMessage) ProtoMessage()
func (*CutOfMessage) ProtoReflect ¶
func (x *CutOfMessage) ProtoReflect() protoreflect.Message
func (*CutOfMessage) Reset ¶
func (x *CutOfMessage) Reset()
func (*CutOfMessage) String ¶
func (x *CutOfMessage) String() string
type ElectionPorts ¶
type ElectionPorts struct { ListOfPorts []int32 `protobuf:"varint,1,rep,packed,name=listOfPorts,proto3" json:"listOfPorts,omitempty"` // contains filtered or unexported fields }
func (*ElectionPorts) Descriptor
deprecated
func (*ElectionPorts) Descriptor() ([]byte, []int)
Deprecated: Use ElectionPorts.ProtoReflect.Descriptor instead.
func (*ElectionPorts) GetListOfPorts ¶
func (x *ElectionPorts) GetListOfPorts() []int32
func (*ElectionPorts) ProtoMessage ¶
func (*ElectionPorts) ProtoMessage()
func (*ElectionPorts) ProtoReflect ¶
func (x *ElectionPorts) ProtoReflect() protoreflect.Message
func (*ElectionPorts) Reset ¶
func (x *ElectionPorts) Reset()
func (*ElectionPorts) String ¶
func (x *ElectionPorts) String() string
type LamportClock ¶
type LamportClock struct {
// contains filtered or unexported fields
}
func (*LamportClock) GetTime ¶
func (c *LamportClock) GetTime() uint32
func (*LamportClock) SyncClocks ¶
func (c *LamportClock) SyncClocks(otherClock uint32)
func (*LamportClock) Tick ¶
func (c *LamportClock) Tick()
type Message ¶
type Message struct { User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"` Timestamp uint32 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetTimestamp ¶
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type PortIndex ¶
type PortIndex struct { Index int32 `protobuf:"varint,1,opt,name=index,proto3" json:"index,omitempty"` // contains filtered or unexported fields }
func (*PortIndex) Descriptor
deprecated
func (*PortIndex) ProtoMessage ¶
func (*PortIndex) ProtoMessage()
func (*PortIndex) ProtoReflect ¶
func (x *PortIndex) ProtoReflect() protoreflect.Message
type PortsAndClocks ¶
type PortsAndClocks struct { ListOfPorts []int32 `protobuf:"varint,1,rep,packed,name=listOfPorts,proto3" json:"listOfPorts,omitempty"` ListOfClocks []uint32 `protobuf:"varint,2,rep,packed,name=listOfClocks,proto3" json:"listOfClocks,omitempty"` // contains filtered or unexported fields }
func (*PortsAndClocks) Descriptor
deprecated
func (*PortsAndClocks) Descriptor() ([]byte, []int)
Deprecated: Use PortsAndClocks.ProtoReflect.Descriptor instead.
func (*PortsAndClocks) GetListOfClocks ¶
func (x *PortsAndClocks) GetListOfClocks() []uint32
func (*PortsAndClocks) GetListOfPorts ¶
func (x *PortsAndClocks) GetListOfPorts() []int32
func (*PortsAndClocks) ProtoMessage ¶
func (*PortsAndClocks) ProtoMessage()
func (*PortsAndClocks) ProtoReflect ¶
func (x *PortsAndClocks) ProtoReflect() protoreflect.Message
func (*PortsAndClocks) Reset ¶
func (x *PortsAndClocks) Reset()
func (*PortsAndClocks) String ¶
func (x *PortsAndClocks) String() string
type ReplicateMessage ¶
type ReplicateMessage struct { Amount int32 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"` User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Timestamp uint32 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
func (*ReplicateMessage) Descriptor
deprecated
func (*ReplicateMessage) Descriptor() ([]byte, []int)
Deprecated: Use ReplicateMessage.ProtoReflect.Descriptor instead.
func (*ReplicateMessage) GetAmount ¶
func (x *ReplicateMessage) GetAmount() int32
func (*ReplicateMessage) GetTimestamp ¶
func (x *ReplicateMessage) GetTimestamp() uint32
func (*ReplicateMessage) GetUser ¶
func (x *ReplicateMessage) GetUser() *User
func (*ReplicateMessage) ProtoMessage ¶
func (*ReplicateMessage) ProtoMessage()
func (*ReplicateMessage) ProtoReflect ¶
func (x *ReplicateMessage) ProtoReflect() protoreflect.Message
func (*ReplicateMessage) Reset ¶
func (x *ReplicateMessage) Reset()
func (*ReplicateMessage) String ¶
func (x *ReplicateMessage) String() string
type ReplyMessage ¶
type ReplyMessage struct { ServerId int32 `protobuf:"varint,1,opt,name=serverId,proto3" json:"serverId,omitempty"` Timestamp int32 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*ReplyMessage) Descriptor
deprecated
func (*ReplyMessage) Descriptor() ([]byte, []int)
Deprecated: Use ReplyMessage.ProtoReflect.Descriptor instead.
func (*ReplyMessage) GetPort ¶
func (x *ReplyMessage) GetPort() int32
func (*ReplyMessage) GetServerId ¶
func (x *ReplyMessage) GetServerId() int32
func (*ReplyMessage) GetTimestamp ¶
func (x *ReplyMessage) GetTimestamp() int32
func (*ReplyMessage) ProtoMessage ¶
func (*ReplyMessage) ProtoMessage()
func (*ReplyMessage) ProtoReflect ¶
func (x *ReplyMessage) ProtoReflect() protoreflect.Message
func (*ReplyMessage) Reset ¶
func (x *ReplyMessage) Reset()
func (*ReplyMessage) String ¶
func (x *ReplyMessage) String() string
type RequestMessage ¶
type RequestMessage struct { ServerId int32 `protobuf:"varint,1,opt,name=serverId,proto3" json:"serverId,omitempty"` Timestamp int32 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Port int32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*RequestMessage) Descriptor
deprecated
func (*RequestMessage) Descriptor() ([]byte, []int)
Deprecated: Use RequestMessage.ProtoReflect.Descriptor instead.
func (*RequestMessage) GetPort ¶
func (x *RequestMessage) GetPort() int32
func (*RequestMessage) GetServerId ¶
func (x *RequestMessage) GetServerId() int32
func (*RequestMessage) GetTimestamp ¶
func (x *RequestMessage) GetTimestamp() int32
func (*RequestMessage) ProtoMessage ¶
func (*RequestMessage) ProtoMessage()
func (*RequestMessage) ProtoReflect ¶
func (x *RequestMessage) ProtoReflect() protoreflect.Message
func (*RequestMessage) Reset ¶
func (x *RequestMessage) Reset()
func (*RequestMessage) String ¶
func (x *RequestMessage) String() string
type ResultMessage ¶
type ResultMessage struct { Amount int32 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"` User *User `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"` Timestamp uint32 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` StillActive bool `protobuf:"varint,4,opt,name=stillActive,proto3" json:"stillActive,omitempty"` // contains filtered or unexported fields }
func (*ResultMessage) Descriptor
deprecated
func (*ResultMessage) Descriptor() ([]byte, []int)
Deprecated: Use ResultMessage.ProtoReflect.Descriptor instead.
func (*ResultMessage) GetAmount ¶
func (x *ResultMessage) GetAmount() int32
func (*ResultMessage) GetStillActive ¶
func (x *ResultMessage) GetStillActive() bool
func (*ResultMessage) GetTimestamp ¶
func (x *ResultMessage) GetTimestamp() uint32
func (*ResultMessage) GetUser ¶
func (x *ResultMessage) GetUser() *User
func (*ResultMessage) ProtoMessage ¶
func (*ResultMessage) ProtoMessage()
func (*ResultMessage) ProtoReflect ¶
func (x *ResultMessage) ProtoReflect() protoreflect.Message
func (*ResultMessage) Reset ¶
func (x *ResultMessage) Reset()
func (*ResultMessage) String ¶
func (x *ResultMessage) String() string
type TimeMessage ¶
type TimeMessage struct { AuctionStart string `protobuf:"bytes,1,opt,name=auctionStart,proto3" json:"auctionStart,omitempty"` Duration int32 `protobuf:"varint,2,opt,name=duration,proto3" json:"duration,omitempty"` // contains filtered or unexported fields }
func (*TimeMessage) Descriptor
deprecated
func (*TimeMessage) Descriptor() ([]byte, []int)
Deprecated: Use TimeMessage.ProtoReflect.Descriptor instead.
func (*TimeMessage) GetAuctionStart ¶
func (x *TimeMessage) GetAuctionStart() string
func (*TimeMessage) GetDuration ¶
func (x *TimeMessage) GetDuration() int32
func (*TimeMessage) ProtoMessage ¶
func (*TimeMessage) ProtoMessage()
func (*TimeMessage) ProtoReflect ¶
func (x *TimeMessage) ProtoReflect() protoreflect.Message
func (*TimeMessage) Reset ¶
func (x *TimeMessage) Reset()
func (*TimeMessage) String ¶
func (x *TimeMessage) String() string
type UnimplementedAuctionHouseServer ¶
type UnimplementedAuctionHouseServer struct { }
UnimplementedAuctionHouseServer must be embedded to have forward compatible implementations.
func (UnimplementedAuctionHouseServer) AccessCritical ¶
func (UnimplementedAuctionHouseServer) AccessCritical(context.Context, *RequestMessage) (*ReplyMessage, error)
func (UnimplementedAuctionHouseServer) Bid ¶
func (UnimplementedAuctionHouseServer) Bid(context.Context, *BidMessage) (*BidReply, error)
func (UnimplementedAuctionHouseServer) BroadcastNewLeader ¶
func (UnimplementedAuctionHouseServer) BroadcastNewLeader(context.Context, *ElectionPorts) (*Void, error)
func (UnimplementedAuctionHouseServer) CloseConnection ¶
func (UnimplementedAuctionHouseServer) CutOfReplicate ¶
func (UnimplementedAuctionHouseServer) CutOfReplicate(context.Context, *CutOfMessage) (*Void, error)
func (UnimplementedAuctionHouseServer) OpenConnection ¶
func (UnimplementedAuctionHouseServer) OpenConnection(*Connect, AuctionHouse_OpenConnectionServer) error
func (UnimplementedAuctionHouseServer) PromptTimeAndDuration ¶
func (UnimplementedAuctionHouseServer) PromptTimeAndDuration(context.Context, *Void) (*TimeMessage, error)
func (UnimplementedAuctionHouseServer) ReceiveReply ¶
func (UnimplementedAuctionHouseServer) ReceiveReply(context.Context, *ReplyMessage) (*Void, error)
func (UnimplementedAuctionHouseServer) ReceiveRequest ¶
func (UnimplementedAuctionHouseServer) ReceiveRequest(context.Context, *RequestMessage) (*Void, error)
func (UnimplementedAuctionHouseServer) RegisterPulse ¶
func (UnimplementedAuctionHouseServer) Replicate ¶
func (UnimplementedAuctionHouseServer) Replicate(context.Context, *ReplicateMessage) (*BidReply, error)
func (UnimplementedAuctionHouseServer) Result ¶
func (UnimplementedAuctionHouseServer) Result(context.Context, *Void) (*ResultMessage, error)
func (UnimplementedAuctionHouseServer) RingElection ¶
func (UnimplementedAuctionHouseServer) RingElection(context.Context, *PortsAndClocks) (*Void, error)
func (UnimplementedAuctionHouseServer) SelectNewLeader ¶
func (UnimplementedAuctionHouseServer) SelectNewLeader(context.Context, *Void) (*ElectionPorts, error)
func (UnimplementedAuctionHouseServer) SetStateReleased ¶
type UnsafeAuctionHouseServer ¶
type UnsafeAuctionHouseServer interface {
// contains filtered or unexported methods
}
UnsafeAuctionHouseServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AuctionHouseServer will result in compilation errors.
type User ¶
type User struct { Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*User) Descriptor
deprecated
func (*User) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶
func (x *User) ProtoReflect() protoreflect.Message
type Void ¶
type Void struct {
// contains filtered or unexported fields
}
func (*Void) Descriptor
deprecated
func (*Void) ProtoMessage ¶
func (*Void) ProtoMessage()
func (*Void) ProtoReflect ¶
func (x *Void) ProtoReflect() protoreflect.Message