ipb

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
}

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
}

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
}

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

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
}

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

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

type UnimplementedSynchronizerServer struct {
}

type UnsafeSynchronizerServer interface {
	// contains filtered or unexported methods
}