etcd: kubedb.dev/etcd/pkg/util Index | Files

package util

import "kubedb.dev/etcd/pkg/util"

Index

Package Files

etcd.go event.go k8sutil.go member.go

Constants

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"
)
const (
    EtcdVersionAnnotationKey = "etcd.version"

    EtcdClientPort = 2379
)
const DefaultTimeoutSecond = 5 * time.Second

func GetEtcdVersion Uses

func GetEtcdVersion(pod *v1.Pod) string

func GetPodNames Uses

func GetPodNames(pods []*v1.Pod) []string

func ListMembers Uses

func ListMembers(clientURLs []string, tc *tls.Config) (*clientv3.MemberListResponse, error)

func MemberNameFromPeerURL Uses

func MemberNameFromPeerURL(pu string) (string, error)

func MemberRemoveEvent Uses

func MemberRemoveEvent(memberName string, cl *api.Etcd) *v1.Event

func MemberUpgradedEvent Uses

func MemberUpgradedEvent(memberName string, oldVersion, newVersion types.StrYo, cl *api.Etcd) *v1.Event

func NewMemberAddEvent Uses

func NewMemberAddEvent(memberName string, cl *api.Etcd) *v1.Event

func RemoveMember Uses

func RemoveMember(clientURLs []string, tc *tls.Config, id uint64) error

func ReplacingDeadMemberEvent Uses

func ReplacingDeadMemberEvent(memberName string, cl *api.Etcd) *v1.Event

func UniqueMemberName Uses

func UniqueMemberName(clusterName string) string

type Member Uses

type Member struct {
    Name      string
    Namespace string
    Service   string

    ID  uint64

    SecureClient bool
    SecurePeer   bool
}

func NewMember Uses

func NewMember(name, namespace, service string) *Member

func (*Member) Addr Uses

func (m *Member) Addr() string

func (*Member) BuildEtcdArgs Uses

func (m *Member) BuildEtcdArgs() []string

func (*Member) ClientURL Uses

func (m *Member) ClientURL() string

func (*Member) ListenClientURL Uses

func (m *Member) ListenClientURL() string

func (*Member) ListenPeerURL Uses

func (m *Member) ListenPeerURL() string

func (*Member) PeerURL Uses

func (m *Member) PeerURL() string

type MemberSet Uses

type MemberSet map[string]*Member

func NewMemberSet Uses

func NewMemberSet(ms ...*Member) MemberSet

func (MemberSet) Add Uses

func (ms MemberSet) Add(m *Member)

func (MemberSet) ClientURLs Uses

func (ms MemberSet) ClientURLs() []string

func (MemberSet) Diff Uses

func (ms MemberSet) Diff(other MemberSet) MemberSet

func (MemberSet) IsEqual Uses

func (ms MemberSet) IsEqual(other MemberSet) bool

func (MemberSet) PeerURLPairs Uses

func (ms MemberSet) PeerURLPairs() []string

func (MemberSet) PickOne Uses

func (ms MemberSet) PickOne() *Member

func (MemberSet) Remove Uses

func (ms MemberSet) Remove(name string)

func (MemberSet) Size Uses

func (ms MemberSet) Size() int

Package util imports 15 packages (graph) and is imported by 4 packages. Updated 2019-07-24. Refresh now. Tools for package owners.