dcomm

type Client interface {
	Put(ctx context.Context, key, value string) error
	Get(ctx context.Context, key string) (string, error)
	//GetWithPrefix 按前缀获取数据
	GetWithPrefix(ctx context.Context, prefix string) ([]KV, error)
	Delete(ctx context.Context, key string) error
	Watch(ctx context.Context, key string) (<-chan struct{}, error)
	WatchPrefix(ctx context.Context, prefix string) (<-chan struct{}, error)
	WatchFunc(ctx context.Context, key string, f func()) error
	WatchFuncPrefix(ctx context.Context, prefix string, f func()) error
	//WatchOnce 针对某个key有且只能watch一次
	WatchOnce(ctx context.Context, key string) (<-chan struct{}, error)
	//WatchOncePrefix 针对某个前缀有且只能watch一次
	// <-chan struct{}触发时，可以用GetWithPrefix获取最新数据
	WatchOncePrefix(ctx context.Context, prefix string) (<-chan struct{}, error)
	Close()
}

type ClientOptions struct {
	Cert          string
	Key           string
	CACert        string
	DialTimeout   time.Duration
	DialKeepAlive time.Duration
}

type DiscoverSettings struct {
	// Limit is the number of peers to discover, use < 1 for unlimited.
	Limit int
	// Port is the port to broadcast on (the peers must also broadcast using the same port).
	// The default port is 9999.
	Port string
	// MulticastAddress specifies the multicast address.
	// You should be able to use any of 224.0.0.0/4 or ff00::/8.
	// By default it uses the Simple Service Discovery Protocol
	// address (239.255.255.250 for IPv4 or ff02::c for IPv6).
	MulticastAddress string
	// Payload is the bytes that are sent out with each broadcast. Must be short.
	Payload []byte
	// PayloadFunc is the function that will be called to dynamically generate payload
	// before every broadcast. If this pointer is nil `Payload` field will be broadcasted instead.
	PayloadFunc func() []byte
	// Delay is the amount of time between broadcasts. The default delay is 1 second.
	Delay time.Duration
	// TimeLimit is the amount of time to spend discovering, if the limit is not reached.
	// A negative limit indiciates scanning until the limit was reached or, if an
	// unlimited scanning was requested, no timeout.
	// The default time limit is 10 seconds.
	TimeLimit time.Duration
	// StopChan is a channel to stop the peer discvoery immediatley after reception.
	StopChan chan struct{}
	// AllowSelf will allow discovery the local machine (default false)
	AllowSelf bool
	// DisableBroadcast will not allow sending out a broadcast
	DisableBroadcast bool
	// IPVersion specifies the version of the Internet Protocol (default IPv4)
	IPVersion IPVersion
	// Notify will be called each time a new peer was discovered.
	// The default is nil, which means no notification whatsoever.
	Notify func(Discovered)
	// contains filtered or unexported fields
}

type Discovered struct {
	// Address is the local address of a discovered peer.
	Address string
	// Payload is the associated payload from discovered peer.
	Payload []byte
}

type HttpResponse struct {
	// contains filtered or unexported fields
}

type IPVersion uint

type KV interface {
	GetKey() string
	GetValue() string
}

type NetPacketConn interface {
	JoinGroup(ifi *net.Interface, group net.Addr) error
	SetMulticastInterface(ini *net.Interface) error
	SetMulticastTTL(int) error
	ReadFrom(buf []byte) (int, net.Addr, error)
	WriteTo(buf []byte, dst net.Addr) (int, error)
}

type PacketConn4 struct {
	*ipv4.PacketConn
}

type PacketConn6 struct {
	*ipv6.PacketConn
}

type TcpClient struct {
	// contains filtered or unexported fields
}

type TcpHandler func([]byte)