ipb

package
v0.7.0-rc.1 Latest Latest
Warning

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

 Go to latest Published: Sep 18, 2019 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterSynchronizerServer 

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

Types

type EvaluateProposalsRequest 

type EvaluateProposalsRequest struct {
	// List of proposals to evaluate in the current synchronization cycle.
	Match *pb.Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	// Identifier for this request issued during request registration.
	Id                   string   `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EvaluateProposalsRequest) Descriptor 

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

func (*EvaluateProposalsRequest) GetId 

func (m *EvaluateProposalsRequest) GetId() string

func (*EvaluateProposalsRequest) GetMatch 

func (m *EvaluateProposalsRequest) GetMatch() *pb.Match

func (*EvaluateProposalsRequest) ProtoMessage 

func (*EvaluateProposalsRequest) ProtoMessage()

func (*EvaluateProposalsRequest) Reset 

func (m *EvaluateProposalsRequest) Reset()

func (*EvaluateProposalsRequest) String 

func (m *EvaluateProposalsRequest) String() string

func (*EvaluateProposalsRequest) XXX_DiscardUnknown 

func (m *EvaluateProposalsRequest) XXX_DiscardUnknown()

func (*EvaluateProposalsRequest) XXX_Marshal 

func (m *EvaluateProposalsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluateProposalsRequest) XXX_Merge 

func (m *EvaluateProposalsRequest) XXX_Merge(src proto.Message)

func (*EvaluateProposalsRequest) XXX_Size 

func (m *EvaluateProposalsRequest) XXX_Size() int

func (*EvaluateProposalsRequest) XXX_Unmarshal 

func (m *EvaluateProposalsRequest) XXX_Unmarshal(b []byte) error

type EvaluateProposalsResponse 

type EvaluateProposalsResponse struct {
	// Results from evaluating proposals for this request.
	Match                *pb.Match `protobuf:"bytes,1,opt,name=match,proto3" json:"match,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*EvaluateProposalsResponse) Descriptor 

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

func (*EvaluateProposalsResponse) GetMatch 

func (m *EvaluateProposalsResponse) GetMatch() *pb.Match

func (*EvaluateProposalsResponse) ProtoMessage 

func (*EvaluateProposalsResponse) ProtoMessage()

func (*EvaluateProposalsResponse) Reset 

func (m *EvaluateProposalsResponse) Reset()

func (*EvaluateProposalsResponse) String 

func (m *EvaluateProposalsResponse) String() string

func (*EvaluateProposalsResponse) XXX_DiscardUnknown 

func (m *EvaluateProposalsResponse) XXX_DiscardUnknown()

func (*EvaluateProposalsResponse) XXX_Marshal 

func (m *EvaluateProposalsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EvaluateProposalsResponse) XXX_Merge 

func (m *EvaluateProposalsResponse) XXX_Merge(src proto.Message)

func (*EvaluateProposalsResponse) XXX_Size 

func (m *EvaluateProposalsResponse) XXX_Size() int

func (*EvaluateProposalsResponse) XXX_Unmarshal 

func (m *EvaluateProposalsResponse) XXX_Unmarshal(b []byte) error

type RegisterRequest 

type RegisterRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterRequest) XXX_Merge 

func (m *RegisterRequest) XXX_Merge(src proto.Message)

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

func (m *RegisterRequest) XXX_Unmarshal(b []byte) error

type RegisterResponse 

type RegisterResponse struct {
	// Identifier for this request valid for the current synchronization cycle.
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) GetId 

func (m *RegisterResponse) GetId() string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterResponse) XXX_Merge 

func (m *RegisterResponse) XXX_Merge(src proto.Message)

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

func (m *RegisterResponse) XXX_Unmarshal(b []byte) error

type SynchronizerClient 

type SynchronizerClient interface {
	// Register associates this request with the current synchronization cycle and
	// returns an identifier for this registration. The caller returns this
	// identifier back in the evaluation request. This enables synchronizer to
	// identify stale evaluation requests belonging to a prior window.
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	// EvaluateProposals accepts a list of proposals and a registration identifier
	// for this request. If the synchronization cycle to which the request was
	// registered is completed, this request fails otherwise the proposals are
	// added to the list of proposals to be evaluated in the current cycle. At the
	//  end of the cycle, the user defined evaluation method is triggered and the
	// matches accepted by it are returned as results.
	EvaluateProposals(ctx context.Context, opts ...grpc.CallOption) (Synchronizer_EvaluateProposalsClient, 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.ClientConn) SynchronizerClient

type SynchronizerServer 

type SynchronizerServer interface {
	// Register associates this request with the current synchronization cycle and
	// returns an identifier for this registration. The caller returns this
	// identifier back in the evaluation request. This enables synchronizer to
	// identify stale evaluation requests belonging to a prior window.
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	// EvaluateProposals accepts a list of proposals and a registration identifier
	// for this request. If the synchronization cycle to which the request was
	// registered is completed, this request fails otherwise the proposals are
	// added to the list of proposals to be evaluated in the current cycle. At the
	//  end of the cycle, the user defined evaluation method is triggered and the
	// matches accepted by it are returned as results.
	EvaluateProposals(Synchronizer_EvaluateProposalsServer) error
}

SynchronizerServer is the server API for Synchronizer service.

type Synchronizer_EvaluateProposalsClient 

type Synchronizer_EvaluateProposalsClient interface {
	Send(*EvaluateProposalsRequest) error
	Recv() (*EvaluateProposalsResponse, error)
	grpc.ClientStream
}

type Synchronizer_EvaluateProposalsServer 

type Synchronizer_EvaluateProposalsServer interface {
	Send(*EvaluateProposalsResponse) error
	Recv() (*EvaluateProposalsRequest, error)
	grpc.ServerStream
}

type UnimplementedSynchronizerServer 

type UnimplementedSynchronizerServer struct {
}

UnimplementedSynchronizerServer can be embedded to have forward compatible implementations.

func (*UnimplementedSynchronizerServer) EvaluateProposals 

func (*UnimplementedSynchronizerServer) EvaluateProposals(srv Synchronizer_EvaluateProposalsServer) error

func (*UnimplementedSynchronizerServer) Register 

func (*UnimplementedSynchronizerServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, 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.