Versions in this module Expand all Collapse all v3 v3.4.16 Apr 15, 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 StresserType_name = map[int32]string + var StresserType_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 + LogLevel string + LogOutputs []string + Logger string + Name string + PeerAutoTLS bool + PeerCertFile string + PeerClientCertAuth bool + PeerKeyFile string + PeerTrustedCAFile string + PreVote bool + QuotaBackendBytes int64 + SnapshotCount int64 + WALDir string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Etcd) Descriptor() ([]byte, []int) + func (*Etcd) ProtoMessage() + func (e *Etcd) Flags() (fs []string) + func (m *Etcd) Marshal() (dAtA []byte, err error) + func (m *Etcd) MarshalTo(dAtA []byte) (int, error) + func (m *Etcd) MarshalToSizedBuffer(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 + func (m *Etcd) XXX_DiscardUnknown() + func (m *Etcd) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Etcd) XXX_Merge(src proto.Message) + func (m *Etcd) XXX_Size() int + func (m *Etcd) XXX_Unmarshal(b []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 + EtcdExec string + EtcdOnSnapshotRestore *Etcd + EtcdPeerProxy bool + FailpointHTTPAddr string + PeerCertData string + PeerCertPath string + PeerKeyData string + PeerKeyPath string + PeerTrustedCAData string + PeerTrustedCAPath string + SnapshotInfo *SnapshotInfo + SnapshotPath string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(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 + func (m *Member) XXX_DiscardUnknown() + func (m *Member) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Member) XXX_Merge(src proto.Message) + func (m *Member) XXX_Size() int + func (m *Member) XXX_Unmarshal(b []byte) 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 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(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 + func (m *Request) XXX_DiscardUnknown() + func (m *Request) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Request) XXX_Merge(src proto.Message) + func (m *Request) XXX_Size() int + func (m *Request) XXX_Unmarshal(b []byte) error + type Response struct + Member *Member + SnapshotInfo *SnapshotInfo + Status string + Success bool + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(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 + func (m *Response) XXX_DiscardUnknown() + func (m *Response) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Response) XXX_Merge(src proto.Message) + func (m *Response) XXX_Size() int + func (m *Response) XXX_Unmarshal(b []byte) error + type SnapshotInfo struct + MemberClientURLs []string + MemberName string + SnapshotFileSize string + SnapshotHash int64 + SnapshotPath string + SnapshotRevision int64 + SnapshotTotalKey int64 + SnapshotTotalSize string + Took string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(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 + func (m *SnapshotInfo) XXX_DiscardUnknown() + func (m *SnapshotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SnapshotInfo) XXX_Merge(src proto.Message) + func (m *SnapshotInfo) XXX_Size() int + func (m *SnapshotInfo) XXX_Unmarshal(b []byte) error + type Stresser struct + Type string + Weight float64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Stresser) Descriptor() ([]byte, []int) + func (*Stresser) ProtoMessage() + func (m *Stresser) Marshal() (dAtA []byte, err error) + func (m *Stresser) MarshalTo(dAtA []byte) (int, error) + func (m *Stresser) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Stresser) Reset() + func (m *Stresser) Size() (n int) + func (m *Stresser) String() string + func (m *Stresser) Unmarshal(dAtA []byte) error + func (m *Stresser) XXX_DiscardUnknown() + func (m *Stresser) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Stresser) XXX_Merge(src proto.Message) + func (m *Stresser) XXX_Size() int + func (m *Stresser) XXX_Unmarshal(b []byte) error + type StresserType int32 + const StresserType_ELECTION_RUNNER + const StresserType_KV_DELETE_ONE_KEY + const StresserType_KV_DELETE_RANGE + const StresserType_KV_READ_ONE_KEY + const StresserType_KV_READ_RANGE + const StresserType_KV_TXN_WRITE_DELETE + const StresserType_KV_WRITE_LARGE + const StresserType_KV_WRITE_SMALL + const StresserType_LEASE + const StresserType_LEASE_RUNNER + const StresserType_LOCK_RACER_RUNNER + const StresserType_WATCH_RUNNER + func (StresserType) EnumDescriptor() ([]byte, []int) + func (x StresserType) 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 []*Stresser + UpdatedDelayLatencyMs uint32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + 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) MarshalToSizedBuffer(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 + func (m *Tester) XXX_DiscardUnknown() + func (m *Tester) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Tester) XXX_Merge(src proto.Message) + func (m *Tester) XXX_Size() int + func (m *Tester) XXX_Unmarshal(b []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 + type UnimplementedTransportServer struct + func (*UnimplementedTransportServer) Transport(srv Transport_TransportServer) error v3.4.15-cyral.1 Apr 15, 2021 Other modules containing this package github.com/cyralinc/etcd
Go to main page