Documentation ¶
Index ¶
- Constants
- func GetEtcdVersion(pod *v1.Pod) string
- func GetPodNames(pods []*v1.Pod) []string
- func ListMembers(clientURLs []string, tc *tls.Config) (*clientv3.MemberListResponse, error)
- func MemberNameFromPeerURL(pu string) (string, error)
- func MemberRemoveEvent(memberName string, cl *api.Etcd) *v1.Event
- func MemberUpgradedEvent(memberName string, oldVersion, newVersion types.StrYo, cl *api.Etcd) *v1.Event
- func NewMemberAddEvent(memberName string, cl *api.Etcd) *v1.Event
- func RemoveMember(clientURLs []string, tc *tls.Config, id uint64) error
- func ReplacingDeadMemberEvent(memberName string, cl *api.Etcd) *v1.Event
- func UniqueMemberName(clusterName string) string
- type Member
- type MemberSet
- func (ms MemberSet) Add(m *Member)
- func (ms MemberSet) ClientURLs() []string
- func (ms MemberSet) Diff(other MemberSet) MemberSet
- func (ms MemberSet) IsEqual(other MemberSet) bool
- func (ms MemberSet) PeerURLPairs() []string
- func (ms MemberSet) PickOne() *Member
- func (ms MemberSet) Remove(name string)
- func (ms MemberSet) Size() int
Constants ¶
View Source
const ( DefaultDialTimeout = 5 * time.Second DefaultRequestTimeout = 5 * time.Second EnvOperatorPodName = "MY_POD_NAME" EnvOperatorPodNamespace = "MY_POD_NAMESPACE" CliCertFile = "etcd-client.crt" CliKeyFile = "etcd-client.key" CliCAFile = "etcd-client-ca.crt" )
View Source
const ( EtcdVersionAnnotationKey = "etcd.version" EtcdClientPort = 2379 )
View Source
const DefaultTimeoutSecond = 5 * time.Second
Variables ¶
This section is empty.
Functions ¶
func GetEtcdVersion ¶
func GetPodNames ¶
func ListMembers ¶
func MemberNameFromPeerURL ¶
func MemberUpgradedEvent ¶
func UniqueMemberName ¶
Types ¶
type Member ¶
type Member struct { Name string Namespace string Service string ID uint64 SecureClient bool SecurePeer bool }
func (*Member) BuildEtcdArgs ¶
func (*Member) ListenClientURL ¶
func (*Member) ListenPeerURL ¶
Click to show internal directories.
Click to hide internal directories.