etcdproxy

Documentation

Index

• type EtcdProxy
  • func NewDisabledEtcdProxy() EtcdProxy
  • func NewEtcdProxy(leaderElection leader.LeaderElection, tlsConfig *tls.Config) EtcdProxy

Types

type EtcdProxy

type EtcdProxy interface {
	// EtcdProxyEnabled returns if the etcd proxy is enabled
	EtcdProxyEnabled() bool

	// Txn forward txn unary request to leader
	Txn(ctx context.Context, txn *etcdserverpb.TxnRequest) (*etcdserverpb.TxnResponse, error)

	// Watch forward watch stream request to leader
	Watch(ctx context.Context, key string, revision uint64) (<-chan []*mvccpb.Event, error)
}

EtcdProxy forward etcd-style rpc request to leader for compatibility of k8s apiserver community edition

func NewDisabledEtcdProxy

func NewDisabledEtcdProxy() EtcdProxy

func NewEtcdProxy

func NewEtcdProxy(leaderElection leader.LeaderElection, tlsConfig *tls.Config) EtcdProxy

NewEtcdProxy return an ETCD proxy for forward request to leader