Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ListReplicatePChannels ¶
func ListReplicatePChannels(ctx context.Context, etcdCli *clientv3.Client, prefix string) ([]*streamingpb.ReplicatePChannelMeta, int64, error)
func MustParseReplicateChannelFromEvent ¶
func MustParseReplicateChannelFromEvent(e *clientv3.Event) *streamingpb.ReplicatePChannelMeta
func NewController ¶
func NewController() *controller
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.