client

package
v1.1.3 Latest Latest
Warning

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

 Go to latest Published: Jan 28, 2022 License: MIT Imports: 23 Imported by: 0

Documentation

Overview

Package client is a generated protocol buffer package.

It is generated from these files: 

client.proto

It has these top-level messages: 

RegisterUsersRequest
RegisterUsersResponse
GenerateMessagesRequest
GenerateMessagesResponse
SubmitMessagesRequest
SubmitMessagesResponse
DownloadMessagesRequest
DownloadMessagesResponse

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthClient = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowClient   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterClientServer 

func RegisterClientServer(s *grpc.Server, srv ClientServer)

Types

type ClientClient 

type ClientClient interface {
	RegisterUsers(ctx context.Context, in *RegisterUsersRequest, opts ...grpc.CallOption) (*RegisterUsersResponse, error)
	GenerateMessages(ctx context.Context, in *GenerateMessagesRequest, opts ...grpc.CallOption) (*GenerateMessagesResponse, error)
	SubmitMessages(ctx context.Context, in *SubmitMessagesRequest, opts ...grpc.CallOption) (*SubmitMessagesResponse, error)
	DownloadMessages(ctx context.Context, in *DownloadMessagesRequest, opts ...grpc.CallOption) (*DownloadMessagesResponse, error)
}

func NewClientClient 

func NewClientClient(cc *grpc.ClientConn) ClientClient

type ClientServer 

type ClientServer interface {
	RegisterUsers(context.Context, *RegisterUsersRequest) (*RegisterUsersResponse, error)
	GenerateMessages(context.Context, *GenerateMessagesRequest) (*GenerateMessagesResponse, error)
	SubmitMessages(context.Context, *SubmitMessagesRequest) (*SubmitMessagesResponse, error)
	DownloadMessages(context.Context, *DownloadMessagesRequest) (*DownloadMessagesResponse, error)
}

func NewClient 

func NewClient(mailboxes, servers map[string]*config.Server, groups map[string]*config.Group) ClientServer

n: number of virtual clients this will handle

type DownloadMessagesRequest 

type DownloadMessagesRequest struct {
	Round uint64 `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
}

func (*DownloadMessagesRequest) Descriptor 

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

func (*DownloadMessagesRequest) GetRound 

func (m *DownloadMessagesRequest) GetRound() uint64

func (*DownloadMessagesRequest) Marshal 

func (m *DownloadMessagesRequest) Marshal() (dAtA []byte, err error)

func (*DownloadMessagesRequest) MarshalTo 

func (m *DownloadMessagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*DownloadMessagesRequest) ProtoMessage 

func (*DownloadMessagesRequest) ProtoMessage()

func (*DownloadMessagesRequest) Reset 

func (m *DownloadMessagesRequest) Reset()

func (*DownloadMessagesRequest) Size 

func (m *DownloadMessagesRequest) Size() (n int)

func (*DownloadMessagesRequest) String 

func (m *DownloadMessagesRequest) String() string

func (*DownloadMessagesRequest) Unmarshal 

func (m *DownloadMessagesRequest) Unmarshal(dAtA []byte) error

type DownloadMessagesResponse 

type DownloadMessagesResponse struct {
}

func (*DownloadMessagesResponse) Descriptor 

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

func (*DownloadMessagesResponse) Marshal 

func (m *DownloadMessagesResponse) Marshal() (dAtA []byte, err error)

func (*DownloadMessagesResponse) MarshalTo 

func (m *DownloadMessagesResponse) MarshalTo(dAtA []byte) (int, error)

func (*DownloadMessagesResponse) ProtoMessage 

func (*DownloadMessagesResponse) ProtoMessage()

func (*DownloadMessagesResponse) Reset 

func (m *DownloadMessagesResponse) Reset()

func (*DownloadMessagesResponse) Size 

func (m *DownloadMessagesResponse) Size() (n int)

func (*DownloadMessagesResponse) String 

func (m *DownloadMessagesResponse) String() string

func (*DownloadMessagesResponse) Unmarshal 

func (m *DownloadMessagesResponse) Unmarshal(dAtA []byte) error

type GenerateMessagesRequest 

type GenerateMessagesRequest struct {
	Round   uint64 `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
	MsgSize uint64 `protobuf:"fixed64,2,opt,name=msg_size,json=msgSize,proto3" json:"msg_size,omitempty"`
}

func (*GenerateMessagesRequest) Descriptor 

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

func (*GenerateMessagesRequest) GetMsgSize 

func (m *GenerateMessagesRequest) GetMsgSize() uint64

func (*GenerateMessagesRequest) GetRound 

func (m *GenerateMessagesRequest) GetRound() uint64

func (*GenerateMessagesRequest) Marshal 

func (m *GenerateMessagesRequest) Marshal() (dAtA []byte, err error)

func (*GenerateMessagesRequest) MarshalTo 

func (m *GenerateMessagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*GenerateMessagesRequest) ProtoMessage 

func (*GenerateMessagesRequest) ProtoMessage()

func (*GenerateMessagesRequest) Reset 

func (m *GenerateMessagesRequest) Reset()

func (*GenerateMessagesRequest) Size 

func (m *GenerateMessagesRequest) Size() (n int)

func (*GenerateMessagesRequest) String 

func (m *GenerateMessagesRequest) String() string

func (*GenerateMessagesRequest) Unmarshal 

func (m *GenerateMessagesRequest) Unmarshal(dAtA []byte) error

type GenerateMessagesResponse 

type GenerateMessagesResponse struct {
}

func (*GenerateMessagesResponse) Descriptor 

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

func (*GenerateMessagesResponse) Marshal 

func (m *GenerateMessagesResponse) Marshal() (dAtA []byte, err error)

func (*GenerateMessagesResponse) MarshalTo 

func (m *GenerateMessagesResponse) MarshalTo(dAtA []byte) (int, error)

func (*GenerateMessagesResponse) ProtoMessage 

func (*GenerateMessagesResponse) ProtoMessage()

func (*GenerateMessagesResponse) Reset 

func (m *GenerateMessagesResponse) Reset()

func (*GenerateMessagesResponse) Size 

func (m *GenerateMessagesResponse) Size() (n int)

func (*GenerateMessagesResponse) String 

func (m *GenerateMessagesResponse) String() string

func (*GenerateMessagesResponse) Unmarshal 

func (m *GenerateMessagesResponse) Unmarshal(dAtA []byte) error

type RegisterUsersRequest 

type RegisterUsersRequest struct {
	Round    uint64 `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
	NumUsers uint64 `protobuf:"fixed64,2,opt,name=num_users,json=numUsers,proto3" json:"num_users,omitempty"`
}

func (*RegisterUsersRequest) Descriptor 

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

func (*RegisterUsersRequest) GetNumUsers 

func (m *RegisterUsersRequest) GetNumUsers() uint64

func (*RegisterUsersRequest) GetRound 

func (m *RegisterUsersRequest) GetRound() uint64

func (*RegisterUsersRequest) Marshal 

func (m *RegisterUsersRequest) Marshal() (dAtA []byte, err error)

func (*RegisterUsersRequest) MarshalTo 

func (m *RegisterUsersRequest) MarshalTo(dAtA []byte) (int, error)

func (*RegisterUsersRequest) ProtoMessage 

func (*RegisterUsersRequest) ProtoMessage()

func (*RegisterUsersRequest) Reset 

func (m *RegisterUsersRequest) Reset()

func (*RegisterUsersRequest) Size 

func (m *RegisterUsersRequest) Size() (n int)

func (*RegisterUsersRequest) String 

func (m *RegisterUsersRequest) String() string

func (*RegisterUsersRequest) Unmarshal 

func (m *RegisterUsersRequest) Unmarshal(dAtA []byte) error

type RegisterUsersResponse 

type RegisterUsersResponse struct {
}

func (*RegisterUsersResponse) Descriptor 

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

func (*RegisterUsersResponse) Marshal 

func (m *RegisterUsersResponse) Marshal() (dAtA []byte, err error)

func (*RegisterUsersResponse) MarshalTo 

func (m *RegisterUsersResponse) MarshalTo(dAtA []byte) (int, error)

func (*RegisterUsersResponse) ProtoMessage 

func (*RegisterUsersResponse) ProtoMessage()

func (*RegisterUsersResponse) Reset 

func (m *RegisterUsersResponse) Reset()

func (*RegisterUsersResponse) Size 

func (m *RegisterUsersResponse) Size() (n int)

func (*RegisterUsersResponse) String 

func (m *RegisterUsersResponse) String() string

func (*RegisterUsersResponse) Unmarshal 

func (m *RegisterUsersResponse) Unmarshal(dAtA []byte) error

type SubmitMessagesRequest 

type SubmitMessagesRequest struct {
	Round uint64 `protobuf:"fixed64,1,opt,name=round,proto3" json:"round,omitempty"`
}

func (*SubmitMessagesRequest) Descriptor 

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

func (*SubmitMessagesRequest) GetRound 

func (m *SubmitMessagesRequest) GetRound() uint64

func (*SubmitMessagesRequest) Marshal 

func (m *SubmitMessagesRequest) Marshal() (dAtA []byte, err error)

func (*SubmitMessagesRequest) MarshalTo 

func (m *SubmitMessagesRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubmitMessagesRequest) ProtoMessage 

func (*SubmitMessagesRequest) ProtoMessage()

func (*SubmitMessagesRequest) Reset 

func (m *SubmitMessagesRequest) Reset()

func (*SubmitMessagesRequest) Size 

func (m *SubmitMessagesRequest) Size() (n int)

func (*SubmitMessagesRequest) String 

func (m *SubmitMessagesRequest) String() string

func (*SubmitMessagesRequest) Unmarshal 

func (m *SubmitMessagesRequest) Unmarshal(dAtA []byte) error

type SubmitMessagesResponse 

type SubmitMessagesResponse struct {
}

func (*SubmitMessagesResponse) Descriptor 

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

func (*SubmitMessagesResponse) Marshal 

func (m *SubmitMessagesResponse) Marshal() (dAtA []byte, err error)

func (*SubmitMessagesResponse) MarshalTo 

func (m *SubmitMessagesResponse) MarshalTo(dAtA []byte) (int, error)

func (*SubmitMessagesResponse) ProtoMessage 

func (*SubmitMessagesResponse) ProtoMessage()

func (*SubmitMessagesResponse) Reset 

func (m *SubmitMessagesResponse) Reset()

func (*SubmitMessagesResponse) Size 

func (m *SubmitMessagesResponse) Size() (n int)

func (*SubmitMessagesResponse) String 

func (m *SubmitMessagesResponse) String() string

func (*SubmitMessagesResponse) Unmarshal 

func (m *SubmitMessagesResponse) Unmarshal(dAtA []byte) 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.