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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL