Auction

package
v0.0.0-...-fada182 Latest Latest
Warning

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

Go to latest
Published: Dec 29, 2021 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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)

View Source
var File_Auction_auction_proto protoreflect.FileDescriptor

Functions

func Max

func Max(a uint32, b uint32) uint32

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.

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) Descriptor() ([]byte, []int)

Deprecated: Use BidReply.ProtoReflect.Descriptor instead.

func (*BidReply) GetReturnType

func (x *BidReply) GetReturnType() int32

func (*BidReply) GetTimestamp

func (x *BidReply) GetTimestamp() uint32

func (*BidReply) ProtoMessage

func (*BidReply) ProtoMessage()

func (*BidReply) ProtoReflect

func (x *BidReply) ProtoReflect() protoreflect.Message

func (*BidReply) Reset

func (x *BidReply) Reset()

func (*BidReply) String

func (x *BidReply) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Connect.ProtoReflect.Descriptor instead.

func (*Connect) GetActive

func (x *Connect) GetActive() bool

func (*Connect) GetUser

func (x *Connect) GetUser() *User

func (*Connect) ProtoMessage

func (*Connect) ProtoMessage()

func (*Connect) ProtoReflect

func (x *Connect) ProtoReflect() protoreflect.Message

func (*Connect) Reset

func (x *Connect) Reset()

func (*Connect) String

func (x *Connect) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetTimestamp

func (x *Message) GetTimestamp() uint32

func (*Message) GetUser

func (x *Message) GetUser() *User

func (*Message) ProtoMessage

func (*Message) ProtoMessage()

func (*Message) ProtoReflect

func (x *Message) ProtoReflect() protoreflect.Message

func (*Message) Reset

func (x *Message) Reset()

func (*Message) String

func (x *Message) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use PortIndex.ProtoReflect.Descriptor instead.

func (*PortIndex) GetIndex

func (x *PortIndex) GetIndex() int32

func (*PortIndex) ProtoMessage

func (*PortIndex) ProtoMessage()

func (*PortIndex) ProtoReflect

func (x *PortIndex) ProtoReflect() protoreflect.Message

func (*PortIndex) Reset

func (x *PortIndex) Reset()

func (*PortIndex) String

func (x *PortIndex) String() string

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) Bid

func (UnimplementedAuctionHouseServer) Broadcast

func (UnimplementedAuctionHouseServer) BroadcastNewLeader

func (UnimplementedAuctionHouseServer) CloseConnection

func (UnimplementedAuctionHouseServer) CutOfReplicate

func (UnimplementedAuctionHouseServer) GetID

func (UnimplementedAuctionHouseServer) OpenConnection

func (UnimplementedAuctionHouseServer) PromptTimeAndDuration

func (UnimplementedAuctionHouseServer) ReceiveReply

func (UnimplementedAuctionHouseServer) ReceiveRequest

func (UnimplementedAuctionHouseServer) RegisterPulse

func (UnimplementedAuctionHouseServer) Replicate

func (UnimplementedAuctionHouseServer) Result

func (UnimplementedAuctionHouseServer) RingElection

func (UnimplementedAuctionHouseServer) SelectNewLeader

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) Descriptor() ([]byte, []int)

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetId

func (x *User) GetId() int64

func (*User) GetName

func (x *User) GetName() string

func (*User) ProtoMessage

func (*User) ProtoMessage()

func (*User) ProtoReflect

func (x *User) ProtoReflect() protoreflect.Message

func (*User) Reset

func (x *User) Reset()

func (*User) String

func (x *User) String() string

type Void

type Void struct {
	// contains filtered or unexported fields
}

func (*Void) Descriptor deprecated

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

Deprecated: Use Void.ProtoReflect.Descriptor instead.

func (*Void) ProtoMessage

func (*Void) ProtoMessage()

func (*Void) ProtoReflect

func (x *Void) ProtoReflect() protoreflect.Message

func (*Void) Reset

func (x *Void) Reset()

func (*Void) String

func (x *Void) String() string

Jump to

Keyboard shortcuts

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