Versions in this module Expand all Collapse all v1 v1.0.0 Jan 8, 2021 Changes in this version + var Case_name = map[int32]string + var Case_value = map[string]int32 + var Checker_name = map[int32]string + var Checker_value = map[string]int32 + var ErrIntOverflowRpc = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRpc = fmt.Errorf("proto: negative length found during unmarshaling") + var Operation_name = map[int32]string + var Operation_value = map[string]int32 + var Stresser_name = map[int32]string + var Stresser_value = map[string]int32 + func RegisterTransportServer(s *grpc.Server, srv TransportServer) + type Case int32 + const Case_BLACKHOLE_PEER_PORT_TX_RX_ALL + const Case_BLACKHOLE_PEER_PORT_TX_RX_LEADER + const Case_BLACKHOLE_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT + const Case_BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER + const Case_BLACKHOLE_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT + const Case_BLACKHOLE_PEER_PORT_TX_RX_QUORUM + const Case_DELAY_PEER_PORT_TX_RX_ALL + const Case_DELAY_PEER_PORT_TX_RX_LEADER + const Case_DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT + const Case_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER + const Case_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT + const Case_DELAY_PEER_PORT_TX_RX_QUORUM + const Case_EXTERNAL + const Case_FAILPOINTS + const Case_NO_FAIL_WITH_NO_STRESS_FOR_LIVENESS + const Case_NO_FAIL_WITH_STRESS + const Case_RANDOM_DELAY_PEER_PORT_TX_RX_ALL + const Case_RANDOM_DELAY_PEER_PORT_TX_RX_LEADER + const Case_RANDOM_DELAY_PEER_PORT_TX_RX_LEADER_UNTIL_TRIGGER_SNAPSHOT + const Case_RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER + const Case_RANDOM_DELAY_PEER_PORT_TX_RX_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT + const Case_RANDOM_DELAY_PEER_PORT_TX_RX_QUORUM + const Case_SIGQUIT_AND_REMOVE_LEADER + const Case_SIGQUIT_AND_REMOVE_LEADER_UNTIL_TRIGGER_SNAPSHOT + const Case_SIGQUIT_AND_REMOVE_ONE_FOLLOWER + const Case_SIGQUIT_AND_REMOVE_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT + const Case_SIGQUIT_AND_REMOVE_QUORUM_AND_RESTORE_LEADER_SNAPSHOT_FROM_SCRATCH + const Case_SIGTERM_ALL + const Case_SIGTERM_LEADER + const Case_SIGTERM_LEADER_UNTIL_TRIGGER_SNAPSHOT + const Case_SIGTERM_ONE_FOLLOWER + const Case_SIGTERM_ONE_FOLLOWER_UNTIL_TRIGGER_SNAPSHOT + const Case_SIGTERM_QUORUM + func (Case) EnumDescriptor() ([]byte, []int) + func (x Case) String() string + type Checker int32 + const Checker_KV_HASH + const Checker_LEASE_EXPIRE + const Checker_NO_CHECK + const Checker_RUNNER + func (Checker) EnumDescriptor() ([]byte, []int) + func (x Checker) String() string + type Etcd struct + AdvertiseClientURLs []string + AdvertisePeerURLs []string + ClientAutoTLS bool + ClientCertAuth bool + ClientCertFile string + ClientKeyFile string + ClientTrustedCAFile string + DataDir string + ElectionTimeoutMs int64 + HeartbeatIntervalMs int64 + InitialCluster string + InitialClusterState string + InitialClusterToken string + InitialCorruptCheck bool + ListenClientURLs []string + ListenPeerURLs []string + Name string + PeerAutoTLS bool + PeerCertFile string + PeerClientCertAuth bool + PeerKeyFile string + PeerTrustedCAFile string + PreVote bool + QuotaBackendBytes int64 + SnapshotCount int64 + WALDir string + func (*Etcd) Descriptor() ([]byte, []int) + func (*Etcd) ProtoMessage() + func (cfg *Etcd) Flags() (fs []string) + func (m *Etcd) Marshal() (dAtA []byte, err error) + func (m *Etcd) MarshalTo(dAtA []byte) (int, error) + func (m *Etcd) Reset() + func (m *Etcd) Size() (n int) + func (m *Etcd) String() string + func (m *Etcd) Unmarshal(dAtA []byte) error + type Member struct + AgentAddr string + BaseDir string + ClientCertData string + ClientCertPath string + ClientKeyData string + ClientKeyPath string + ClientTrustedCAData string + ClientTrustedCAPath string + Etcd *Etcd + EtcdClientEndpoint string + EtcdClientProxy bool + EtcdExecPath string + EtcdLogPath string + EtcdOnSnapshotRestore *Etcd + EtcdPeerProxy bool + FailpointHTTPAddr string + PeerCertData string + PeerCertPath string + PeerKeyData string + PeerKeyPath string + PeerTrustedCAData string + PeerTrustedCAPath string + SnapshotInfo *SnapshotInfo + SnapshotPath string + func (*Member) Descriptor() ([]byte, []int) + func (*Member) ProtoMessage() + func (m *Member) CheckCompact(rev int64) error + func (m *Member) Compact(rev int64, timeout time.Duration) error + func (m *Member) CreateEtcdClient(opts ...grpc.DialOption) (*clientv3.Client, error) + func (m *Member) CreateEtcdClientConfig(opts ...grpc.DialOption) (cfg *clientv3.Config, err error) + func (m *Member) Defrag() error + func (m *Member) DialEtcdGRPCServer(opts ...grpc.DialOption) (*grpc.ClientConn, error) + func (m *Member) ElectionTimeout() time.Duration + func (m *Member) IsLeader() (bool, error) + func (m *Member) Marshal() (dAtA []byte, err error) + func (m *Member) MarshalTo(dAtA []byte) (int, error) + func (m *Member) Reset() + func (m *Member) RestoreSnapshot(lg *zap.Logger) (err error) + func (m *Member) Rev(ctx context.Context) (int64, error) + func (m *Member) RevHash() (int64, int64, error) + func (m *Member) SaveSnapshot(lg *zap.Logger) (err error) + func (m *Member) Size() (n int) + func (m *Member) String() string + func (m *Member) Unmarshal(dAtA []byte) error + func (m *Member) WriteHealthKey() error + type Operation int32 + const Operation_BLACKHOLE_PEER_PORT_TX_RX + const Operation_DELAY_PEER_PORT_TX_RX + const Operation_INITIAL_START_ETCD + const Operation_NOT_STARTED + const Operation_RESTART_ETCD + const Operation_RESTART_FROM_SNAPSHOT + const Operation_RESTORE_RESTART_FROM_SNAPSHOT + const Operation_SAVE_SNAPSHOT + const Operation_SIGQUIT_ETCD_AND_ARCHIVE_DATA + const Operation_SIGQUIT_ETCD_AND_REMOVE_DATA + const Operation_SIGQUIT_ETCD_AND_REMOVE_DATA_AND_STOP_AGENT + const Operation_SIGTERM_ETCD + const Operation_UNBLACKHOLE_PEER_PORT_TX_RX + const Operation_UNDELAY_PEER_PORT_TX_RX + func (Operation) EnumDescriptor() ([]byte, []int) + func (x Operation) String() string + type Request struct + Member *Member + Operation Operation + Tester *Tester + func (*Request) Descriptor() ([]byte, []int) + func (*Request) ProtoMessage() + func (m *Request) Marshal() (dAtA []byte, err error) + func (m *Request) MarshalTo(dAtA []byte) (int, error) + func (m *Request) Reset() + func (m *Request) Size() (n int) + func (m *Request) String() string + func (m *Request) Unmarshal(dAtA []byte) error + type Response struct + Member *Member + SnapshotInfo *SnapshotInfo + Status string + Success bool + func (*Response) Descriptor() ([]byte, []int) + func (*Response) ProtoMessage() + func (m *Response) Marshal() (dAtA []byte, err error) + func (m *Response) MarshalTo(dAtA []byte) (int, error) + func (m *Response) Reset() + func (m *Response) Size() (n int) + func (m *Response) String() string + func (m *Response) Unmarshal(dAtA []byte) error + type SnapshotInfo struct + MemberClientURLs []string + MemberName string + SnapshotFileSize string + SnapshotHash int64 + SnapshotPath string + SnapshotRevision int64 + SnapshotTotalKey int64 + SnapshotTotalSize string + Took string + func (*SnapshotInfo) Descriptor() ([]byte, []int) + func (*SnapshotInfo) ProtoMessage() + func (m *SnapshotInfo) Marshal() (dAtA []byte, err error) + func (m *SnapshotInfo) MarshalTo(dAtA []byte) (int, error) + func (m *SnapshotInfo) Reset() + func (m *SnapshotInfo) Size() (n int) + func (m *SnapshotInfo) String() string + func (m *SnapshotInfo) Unmarshal(dAtA []byte) error + type Stresser int32 + const Stresser_ELECTION_RUNNER + const Stresser_KV + const Stresser_LEASE + const Stresser_LEASE_RUNNER + const Stresser_LOCK_RACER_RUNNER + const Stresser_WATCH_RUNNER + func (Stresser) EnumDescriptor() ([]byte, []int) + func (x Stresser) String() string + type Tester struct + Addr string + CaseDelayMs uint32 + CaseShuffle bool + Cases []string + Checkers []string + DataDir string + DelayLatencyMs uint32 + DelayLatencyMsRv uint32 + EnablePprof bool + ExitOnCaseFail bool + ExternalExecPath string + FailpointCommands []string + Network string + RoundLimit int32 + RunnerExecPath string + StressClients int32 + StressKeySize int32 + StressKeySizeLarge int32 + StressKeySuffixRange int32 + StressKeySuffixRangeTxn int32 + StressKeyTxnOps int32 + StressQPS int32 + Stressers []string + UpdatedDelayLatencyMs uint32 + func (*Tester) Descriptor() ([]byte, []int) + func (*Tester) ProtoMessage() + func (m *Tester) Marshal() (dAtA []byte, err error) + func (m *Tester) MarshalTo(dAtA []byte) (int, error) + func (m *Tester) Reset() + func (m *Tester) Size() (n int) + func (m *Tester) String() string + func (m *Tester) Unmarshal(dAtA []byte) error + type TransportClient interface + Transport func(ctx context.Context, opts ...grpc.CallOption) (Transport_TransportClient, error) + func NewTransportClient(cc *grpc.ClientConn) TransportClient + type TransportServer interface + Transport func(Transport_TransportServer) error + type Transport_TransportClient interface + Recv func() (*Response, error) + Send func(*Request) error + type Transport_TransportServer interface + Recv func() (*Request, error) + Send func(*Response) error Incompatible versions in this module v3.3.27+incompatible Aug 25, 2020
Go to main page