ipb

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2021 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_internal_api_messages_proto protoreflect.FileDescriptor
View Source 
var File_internal_api_synchronizer_proto protoreflect.FileDescriptor

Functions

func RegisterSynchronizerServer 

func RegisterSynchronizerServer(s *grpc.Server, srv SynchronizerServer)

Types

type BackfillInternal added in v1.2.0 

type BackfillInternal struct {

	// Represents a backfill entity which is used to fill partially full matches
	Backfill *pb.Backfill `protobuf:"bytes,1,opt,name=backfill,proto3" json:"backfill,omitempty"`
	// List of ticket IDs associated with a current backfill
	TicketIds []string `protobuf:"bytes,2,rep,name=ticket_ids,json=ticketIds,proto3" json:"ticket_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*BackfillInternal) Descriptor deprecated added in v1.2.0 

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

Deprecated: Use BackfillInternal.ProtoReflect.Descriptor instead.

func (*BackfillInternal) GetBackfill added in v1.2.0 

func (x *BackfillInternal) GetBackfill() *pb.Backfill

func (*BackfillInternal) GetTicketIds added in v1.2.0 

func (x *BackfillInternal) GetTicketIds() []string

func (*BackfillInternal) ProtoMessage added in v1.2.0 

func (*BackfillInternal) ProtoMessage()

func (*BackfillInternal) ProtoReflect added in v1.2.0 

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

func (*BackfillInternal) Reset added in v1.2.0 

func (x *BackfillInternal) Reset()

func (*BackfillInternal) String added in v1.2.0 

func (x *BackfillInternal) String() string

type SynchronizeRequest added in v0.9.0 

type SynchronizeRequest struct {

	// A match returned by an mmf.
	Proposal *pb.Match `protobuf:"bytes,1,opt,name=proposal,proto3" json:"proposal,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.

func (*SynchronizeRequest) GetProposal added in v0.9.0 

func (x *SynchronizeRequest) GetProposal() *pb.Match

func (*SynchronizeRequest) ProtoMessage added in v0.9.0 

func (*SynchronizeRequest) ProtoMessage()

func (*SynchronizeRequest) ProtoReflect added in v1.2.0 

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

func (*SynchronizeRequest) Reset added in v0.9.0 

func (x *SynchronizeRequest) Reset()

func (*SynchronizeRequest) String added in v0.9.0 

func (x *SynchronizeRequest) String() string

type SynchronizeResponse added in v0.9.0 

type SynchronizeResponse struct {

	// Instructs the backend call that it can start running the mmfs.
	StartMmfs bool `protobuf:"varint,1,opt,name=start_mmfs,json=startMmfs,proto3" json:"start_mmfs,omitempty"`
	// Instructs the backend call that it should cancel any RPC calls to the mmfs,
	// not send any more matches, and close the send stream.
	CancelMmfs bool `protobuf:"varint,2,opt,name=cancel_mmfs,json=cancelMmfs,proto3" json:"cancel_mmfs,omitempty"`
	// A match ID returned by the evaluator and should be returned to the FetchMatches
	// caller.
	MatchId string `protobuf:"bytes,4,opt,name=match_id,json=matchId,proto3" json:"match_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse) GetCancelMmfs added in v0.9.0 

func (x *SynchronizeResponse) GetCancelMmfs() bool

func (*SynchronizeResponse) GetMatchId added in v0.9.0 

func (x *SynchronizeResponse) GetMatchId() string

func (*SynchronizeResponse) GetStartMmfs added in v0.9.0 

func (x *SynchronizeResponse) GetStartMmfs() bool

func (*SynchronizeResponse) ProtoMessage added in v0.9.0 

func (*SynchronizeResponse) ProtoMessage()

func (*SynchronizeResponse) ProtoReflect added in v1.2.0 

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

func (*SynchronizeResponse) Reset added in v0.9.0 

func (x *SynchronizeResponse) Reset()

func (*SynchronizeResponse) String added in v0.9.0 

func (x *SynchronizeResponse) String() string

type SynchronizerClient 

type SynchronizerClient interface {
	// Synchronize signals the caller when it is safe to run mmfs, collects the
	// mmfs' proposals, and returns the evaluated matches.
	Synchronize(ctx context.Context, opts ...grpc.CallOption) (Synchronizer_SynchronizeClient, error)
}

SynchronizerClient is the client API for Synchronizer service.

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

func NewSynchronizerClient 

func NewSynchronizerClient(cc grpc.ClientConnInterface) SynchronizerClient

type SynchronizerServer 

type SynchronizerServer interface {
	// Synchronize signals the caller when it is safe to run mmfs, collects the
	// mmfs' proposals, and returns the evaluated matches.
	Synchronize(Synchronizer_SynchronizeServer) error
}

SynchronizerServer is the server API for Synchronizer service.

type Synchronizer_SynchronizeClient added in v0.9.0 

type Synchronizer_SynchronizeClient interface {
	Send(*SynchronizeRequest) error
	Recv() (*SynchronizeResponse, error)
	grpc.ClientStream
}

type Synchronizer_SynchronizeServer added in v0.9.0 

type Synchronizer_SynchronizeServer interface {
	Send(*SynchronizeResponse) error
	Recv() (*SynchronizeRequest, error)
	grpc.ServerStream
}

type UnimplementedSynchronizerServer 

type UnimplementedSynchronizerServer struct {
}

UnimplementedSynchronizerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSynchronizerServer) Synchronize added in v0.9.0 

func (*UnimplementedSynchronizerServer) Synchronize(Synchronizer_SynchronizeServer) 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.