masterpb

package
v0.0.0-...-3a733ff Latest Latest
Warning

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

 Go to latest Published: May 24, 2022 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMaster        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMaster          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMaster = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterServiceDiscoveryServer 

func RegisterServiceDiscoveryServer(s *grpc.Server, srv ServiceDiscoveryServer)

Types

type BaseClientConfig 

type BaseClientConfig struct {
	MaxInflightRequests uint32 `protobuf:"varint,1,opt,name=max_inflight_requests,json=maxInflightRequests,proto3" json:"max_inflight_requests,omitempty"`
	TotalRequests       uint32 `protobuf:"varint,2,opt,name=total_requests,json=totalRequests,proto3" json:"total_requests,omitempty"`
	RequestPayloadSize  uint64 `protobuf:"varint,3,opt,name=request_payload_size,json=requestPayloadSize,proto3" json:"request_payload_size,omitempty"`
	RequestOpsBatchSize uint64 `protobuf:"varint,4,opt,name=request_ops_batch_size,json=requestOpsBatchSize,proto3" json:"request_ops_batch_size,omitempty"`
	SleepTimeSeconds    uint64 `protobuf:"varint,5,opt,name=sleep_time_seconds,json=sleepTimeSeconds,proto3" json:"sleep_time_seconds,omitempty"`
	ConflictPercent     uint64 `protobuf:"varint,6,opt,name=conflict_percent,json=conflictPercent,proto3" json:"conflict_percent,omitempty"`
	FastResponsePercent uint64 `protobuf:"varint,7,opt,name=fast_response_percent,json=fastResponsePercent,proto3" json:"fast_response_percent,omitempty"`
	LogVerbose          bool   `protobuf:"varint,8,opt,name=log_verbose,json=logVerbose,proto3" json:"log_verbose,omitempty"`
}

func (*BaseClientConfig) Descriptor 

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

func (*BaseClientConfig) GetConflictPercent 

func (m *BaseClientConfig) GetConflictPercent() uint64

func (*BaseClientConfig) GetFastResponsePercent 

func (m *BaseClientConfig) GetFastResponsePercent() uint64

func (*BaseClientConfig) GetLogVerbose 

func (m *BaseClientConfig) GetLogVerbose() bool

func (*BaseClientConfig) GetMaxInflightRequests 

func (m *BaseClientConfig) GetMaxInflightRequests() uint32

func (*BaseClientConfig) GetRequestOpsBatchSize 

func (m *BaseClientConfig) GetRequestOpsBatchSize() uint64

func (*BaseClientConfig) GetRequestPayloadSize 

func (m *BaseClientConfig) GetRequestPayloadSize() uint64

func (*BaseClientConfig) GetSleepTimeSeconds 

func (m *BaseClientConfig) GetSleepTimeSeconds() uint64

func (*BaseClientConfig) GetTotalRequests 

func (m *BaseClientConfig) GetTotalRequests() uint32

func (*BaseClientConfig) Marshal 

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

func (*BaseClientConfig) MarshalTo 

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

func (*BaseClientConfig) MarshalToSizedBuffer 

func (m *BaseClientConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BaseClientConfig) ProtoMessage 

func (*BaseClientConfig) ProtoMessage()

func (*BaseClientConfig) Reset 

func (m *BaseClientConfig) Reset()

func (*BaseClientConfig) Size 

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

func (*BaseClientConfig) String 

func (m *BaseClientConfig) String() string

func (*BaseClientConfig) Unmarshal 

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

func (*BaseClientConfig) XXX_DiscardUnknown 

func (m *BaseClientConfig) XXX_DiscardUnknown()

func (*BaseClientConfig) XXX_Marshal 

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

func (*BaseClientConfig) XXX_Merge 

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

func (*BaseClientConfig) XXX_Size 

func (m *BaseClientConfig) XXX_Size() int

func (*BaseClientConfig) XXX_Unmarshal 

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

type BaseServerConfig 

type BaseServerConfig struct {
	KeyFile                string                         `protobuf:"bytes,4,opt,name=key_file,json=keyFile,proto3" json:"key_file,omitempty"`
	EnclavePath            string                         `protobuf:"bytes,5,opt,name=enclave_path,json=enclavePath,proto3" json:"enclave_path,omitempty"`
	LogVerbose             bool                           `protobuf:"varint,6,opt,name=log_verbose,json=logVerbose,proto3" json:"log_verbose,omitempty"`
	EnclaveBatchSize       int32                          `protobuf:"varint,7,opt,name=enclave_batch_size,json=enclaveBatchSize,proto3" json:"enclave_batch_size,omitempty"`
	DqOBatchSize           uint32                         `protobuf:"varint,8,opt,name=dq_o_batch_size,json=dqOBatchSize,proto3" json:"dq_o_batch_size,omitempty"`
	DqOBatchTimeout        uint32                         `protobuf:"varint,18,opt,name=dq_o_batch_timeout,json=dqOBatchTimeout,proto3" json:"dq_o_batch_timeout,omitempty"`
	DestinySignerWorkers   uint32                         `protobuf:"varint,9,opt,name=destiny_signer_workers,json=destinySignerWorkers,proto3" json:"destiny_signer_workers,omitempty"`
	Workers                map[string]uint32              `` /* 157-byte string literal not displayed */
	WorkersQueueSizes      map[string]uint32              `` /* 204-byte string literal not displayed */
	CmdBatchSize           uint32                         `protobuf:"varint,11,opt,name=cmd_batch_size,json=cmdBatchSize,proto3" json:"cmd_batch_size,omitempty"`
	CmdBatchTimeout        uint32                         `protobuf:"varint,12,opt,name=cmd_batch_timeout,json=cmdBatchTimeout,proto3" json:"cmd_batch_timeout,omitempty"`
	ReqBufThreshold        int32                          `protobuf:"varint,13,opt,name=req_buf_threshold,json=reqBufThreshold,proto3" json:"req_buf_threshold,omitempty"`
	ThreshsignFastLagrange bool                           `` /* 131-byte string literal not displayed */
	DispelWaitForAllRb     bool                           `protobuf:"varint,16,opt,name=dispel_wait_for_all_rb,json=dispelWaitForAllRb,proto3" json:"dispel_wait_for_all_rb,omitempty"`
	RccAlgorithm           peerpb.Algorithm               `protobuf:"varint,17,opt,name=rcc_algorithm,json=rccAlgorithm,proto3,enum=peerpb.Algorithm" json:"rcc_algorithm,omitempty"`
	MultiChainDuoBFTConfig *peerpb.MultiChainDuoBFTConfig `` /* 130-byte string literal not displayed */
}

func (*BaseServerConfig) Descriptor 

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

func (*BaseServerConfig) GetCmdBatchSize 

func (m *BaseServerConfig) GetCmdBatchSize() uint32

func (*BaseServerConfig) GetCmdBatchTimeout 

func (m *BaseServerConfig) GetCmdBatchTimeout() uint32

func (*BaseServerConfig) GetDestinySignerWorkers 

func (m *BaseServerConfig) GetDestinySignerWorkers() uint32

func (*BaseServerConfig) GetDispelWaitForAllRb 

func (m *BaseServerConfig) GetDispelWaitForAllRb() bool

func (*BaseServerConfig) GetDqOBatchSize 

func (m *BaseServerConfig) GetDqOBatchSize() uint32

func (*BaseServerConfig) GetDqOBatchTimeout 

func (m *BaseServerConfig) GetDqOBatchTimeout() uint32

func (*BaseServerConfig) GetEnclaveBatchSize 

func (m *BaseServerConfig) GetEnclaveBatchSize() int32

func (*BaseServerConfig) GetEnclavePath 

func (m *BaseServerConfig) GetEnclavePath() string

func (*BaseServerConfig) GetKeyFile 

func (m *BaseServerConfig) GetKeyFile() string

func (*BaseServerConfig) GetLogVerbose 

func (m *BaseServerConfig) GetLogVerbose() bool

func (*BaseServerConfig) GetMultiChainDuoBFTConfig 

func (m *BaseServerConfig) GetMultiChainDuoBFTConfig() *peerpb.MultiChainDuoBFTConfig

func (*BaseServerConfig) GetRccAlgorithm 

func (m *BaseServerConfig) GetRccAlgorithm() peerpb.Algorithm

func (*BaseServerConfig) GetReqBufThreshold 

func (m *BaseServerConfig) GetReqBufThreshold() int32

func (*BaseServerConfig) GetThreshsignFastLagrange 

func (m *BaseServerConfig) GetThreshsignFastLagrange() bool

func (*BaseServerConfig) GetWorkers 

func (m *BaseServerConfig) GetWorkers() map[string]uint32

func (*BaseServerConfig) GetWorkersQueueSizes 

func (m *BaseServerConfig) GetWorkersQueueSizes() map[string]uint32

func (*BaseServerConfig) Marshal 

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

func (*BaseServerConfig) MarshalTo 

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

func (*BaseServerConfig) MarshalToSizedBuffer 

func (m *BaseServerConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BaseServerConfig) ProtoMessage 

func (*BaseServerConfig) ProtoMessage()

func (*BaseServerConfig) Reset 

func (m *BaseServerConfig) Reset()

func (*BaseServerConfig) Size 

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

func (*BaseServerConfig) String 

func (m *BaseServerConfig) String() string

func (*BaseServerConfig) Unmarshal 

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

func (*BaseServerConfig) XXX_DiscardUnknown 

func (m *BaseServerConfig) XXX_DiscardUnknown()

func (*BaseServerConfig) XXX_Marshal 

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

func (*BaseServerConfig) XXX_Merge 

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

func (*BaseServerConfig) XXX_Size 

func (m *BaseServerConfig) XXX_Size() int

func (*BaseServerConfig) XXX_Unmarshal 

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

type ClientConfig 

type ClientConfig struct {
	*BaseClientConfig `protobuf:"bytes,1,opt,name=config,proto3,embedded=config" json:"config,omitempty"`
	Nodes             []peerpb.PeerInfo                                      `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes"`
	Algorithm         peerpb.Algorithm                                       `protobuf:"varint,3,opt,name=algorithm,proto3,enum=peerpb.Algorithm" json:"algorithm,omitempty"`
	MaxFailures       int32                                                  `protobuf:"varint,4,opt,name=max_failures,json=maxFailures,proto3" json:"max_failures,omitempty"`
	MaxFastFailures   int32                                                  `protobuf:"varint,5,opt,name=max_fast_failures,json=maxFastFailures,proto3" json:"max_fast_failures,omitempty"`
	LeaderID          github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 150-byte string literal not displayed */
}

func (*ClientConfig) Descriptor 

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

func (*ClientConfig) GetAlgorithm 

func (m *ClientConfig) GetAlgorithm() peerpb.Algorithm

func (*ClientConfig) GetLeaderID 

func (m *ClientConfig) GetLeaderID() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID

func (*ClientConfig) GetMaxFailures 

func (m *ClientConfig) GetMaxFailures() int32

func (*ClientConfig) GetMaxFastFailures 

func (m *ClientConfig) GetMaxFastFailures() int32

func (*ClientConfig) GetNodes 

func (m *ClientConfig) GetNodes() []peerpb.PeerInfo

func (*ClientConfig) Marshal 

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

func (*ClientConfig) MarshalTo 

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

func (*ClientConfig) MarshalToSizedBuffer 

func (m *ClientConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientConfig) ProtoMessage 

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset 

func (m *ClientConfig) Reset()

func (*ClientConfig) Size 

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

func (*ClientConfig) String 

func (m *ClientConfig) String() string

func (*ClientConfig) Unmarshal 

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

func (*ClientConfig) XXX_DiscardUnknown 

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal 

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

func (*ClientConfig) XXX_Merge 

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

func (*ClientConfig) XXX_Size 

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal 

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

type ClientResponse 

type ClientResponse struct {
	Config   *ClientConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	ClientId uint32        `protobuf:"varint,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
}

func (*ClientResponse) Descriptor 

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

func (*ClientResponse) GetClientId 

func (m *ClientResponse) GetClientId() uint32

func (*ClientResponse) GetConfig 

func (m *ClientResponse) GetConfig() *ClientConfig

func (*ClientResponse) Marshal 

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

func (*ClientResponse) MarshalTo 

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

func (*ClientResponse) MarshalToSizedBuffer 

func (m *ClientResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientResponse) ProtoMessage 

func (*ClientResponse) ProtoMessage()

func (*ClientResponse) Reset 

func (m *ClientResponse) Reset()

func (*ClientResponse) Size 

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

func (*ClientResponse) String 

func (m *ClientResponse) String() string

func (*ClientResponse) Unmarshal 

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

func (*ClientResponse) XXX_DiscardUnknown 

func (m *ClientResponse) XXX_DiscardUnknown()

func (*ClientResponse) XXX_Marshal 

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

func (*ClientResponse) XXX_Merge 

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

func (*ClientResponse) XXX_Size 

func (m *ClientResponse) XXX_Size() int

func (*ClientResponse) XXX_Unmarshal 

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

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

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

func (*Empty) MarshalTo 

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

func (*Empty) MarshalToSizedBuffer 

func (m *Empty) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

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

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

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

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

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

func (*Empty) XXX_Merge 

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

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

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

type ServerResponse 

type ServerResponse struct {
	*peerpb.PeerConfig `protobuf:"bytes,1,opt,name=config,proto3,embedded=config" json:"config,omitempty"`
	PeerID             github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID `` /* 144-byte string literal not displayed */
}

func (*ServerResponse) Descriptor 

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

func (*ServerResponse) GetPeerID 

func (m *ServerResponse) GetPeerID() github_com_ibalajiarun_go_consensus_peer_peerpb.PeerID

func (*ServerResponse) Marshal 

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

func (*ServerResponse) MarshalTo 

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

func (*ServerResponse) MarshalToSizedBuffer 

func (m *ServerResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ServerResponse) ProtoMessage 

func (*ServerResponse) ProtoMessage()

func (*ServerResponse) Reset 

func (m *ServerResponse) Reset()

func (*ServerResponse) Size 

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

func (*ServerResponse) String 

func (m *ServerResponse) String() string

func (*ServerResponse) Unmarshal 

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

func (*ServerResponse) XXX_DiscardUnknown 

func (m *ServerResponse) XXX_DiscardUnknown()

func (*ServerResponse) XXX_Marshal 

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

func (*ServerResponse) XXX_Merge 

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

func (*ServerResponse) XXX_Size 

func (m *ServerResponse) XXX_Size() int

func (*ServerResponse) XXX_Unmarshal 

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

type ServiceDiscoveryClient 

type ServiceDiscoveryClient interface {
	Register(ctx context.Context, in *peerpb.BasicPeerInfo, opts ...grpc.CallOption) (*ServerResponse, error)
	GetServiceInfo(ctx context.Context, in *peerpb.BasicPeerInfo, opts ...grpc.CallOption) (*ClientResponse, error)
}

ServiceDiscoveryClient is the client API for ServiceDiscovery service.

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

func NewServiceDiscoveryClient 

func NewServiceDiscoveryClient(cc *grpc.ClientConn) ServiceDiscoveryClient

type ServiceDiscoveryServer 

type ServiceDiscoveryServer interface {
	Register(context.Context, *peerpb.BasicPeerInfo) (*ServerResponse, error)
	GetServiceInfo(context.Context, *peerpb.BasicPeerInfo) (*ClientResponse, error)
}

ServiceDiscoveryServer is the server API for ServiceDiscovery service.

type UnimplementedServiceDiscoveryServer 

type UnimplementedServiceDiscoveryServer struct {
}

UnimplementedServiceDiscoveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceDiscoveryServer) GetServiceInfo 

func (*UnimplementedServiceDiscoveryServer) GetServiceInfo(ctx context.Context, req *peerpb.BasicPeerInfo) (*ClientResponse, error)

func (*UnimplementedServiceDiscoveryServer) Register 

func (*UnimplementedServiceDiscoveryServer) Register(ctx context.Context, req *peerpb.BasicPeerInfo) (*ServerResponse, 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.