Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dcomm

package

Go to main page

Versions in this module

v0

v0.9.2

Jan 13, 2023

v0.9.1

Dec 7, 2022

v0.9.0

Dec 5, 2022

Changes in this version

+ func MustGRPCClient(address string) *grpc.ClientConn

v0.8.0

Sep 19, 2022

v0.7.0

Sep 6, 2022

v0.6.0

Aug 3, 2022

v0.5.0

Aug 2, 2022

Changes in this version

+ const BufferSize

+ const HeaderSize

+ const Index

+ var ErrNoFunc = errors.New("no function of watch provided")

+ var ErrNoKey = errors.New("no key provided")

+ var ErrNoPrefix = errors.New("no prefix provided")

+ var ErrNoValue = errors.New("no value provided")

+ var ErrorDisonnected = fmt.Errorf("tcp connction is not good")

+ func FormatOutput(in string) string

+ func GRPCClient(address string) (*grpc.ClientConn, error)

+ func GRPCClientNoTrace(address string) (*grpc.ClientConn, error)

+ func GRPCServer(port string) (*grpc.Server, error)

+ func GRPCServerNoTrace(port string) (*grpc.Server, error)

+ func GoDiscoveryBroadcast(ctx context.Context, multicastAddress, port string, ipVersion IPVersion, ...)

+ func HttpFileASyncDownloadWithProcess(url, path string) ...

+ func HttpFileDownload(url, path string) error

+ func NewPkgTcpClient(address string, fun TcpHandler) (*pkgTCPclient, error)

+ func NewPkgTcpServer(port string, fun TcpHandler) (*pkgAsyncTCPServer, error)

+ func NewTcpServer(port string, fun TcpHandler) (*asyncTCPServer, error)

+ func ProcessInput(buffer string) (left string, output string)

+ func PublicIP() string

+ type Client interface

+ Close func()

+ Delete func(ctx context.Context, key string) error

+ Get func(ctx context.Context, key string) (string, error)

+ GetWithPrefix func(ctx context.Context, prefix string) ([]KV, error)

+ Put func(ctx context.Context, key, value string) error

+ Watch func(ctx context.Context, key string) (<-chan struct{}, error)

+ WatchFunc func(ctx context.Context, key string, f func()) error

+ WatchFuncPrefix func(ctx context.Context, prefix string, f func()) error

+ WatchOnce func(ctx context.Context, key string) (<-chan struct{}, error)

+ WatchOncePrefix func(ctx context.Context, prefix string) (<-chan struct{}, error)

+ WatchPrefix func(ctx context.Context, prefix string) (<-chan struct{}, error)

+ func NewETCDClientV3(endpoints []string, options ClientOptions) (Client, error)

+ type ClientOptions struct

+ CACert string

+ Cert string

+ DialKeepAlive time.Duration

+ DialTimeout time.Duration

+ Key string

+ type DiscoverSettings struct

+ AllowSelf bool

+ Delay time.Duration

+ DisableBroadcast bool

+ IPVersion IPVersion

+ Limit int

+ MulticastAddress string

+ Notify func(Discovered)

+ Payload []byte

+ PayloadFunc func() []byte

+ Port string

+ StopChan chan struct{}

+ TimeLimit time.Duration

+ type Discovered struct

+ Address string

+ Payload []byte

+ func Discover(s DiscoverSettings) (discoveries []Discovered, err error)

+ func (d Discovered) String() string

+ type HttpResponse struct

+ func HttpDelete(url string) (*HttpResponse, error)

+ func HttpGet(url string) (*HttpResponse, error)

+ func HttpPost(url string, data []byte) (*HttpResponse, error)

+ func HttpPostWithReader(url string, data io.Reader) (*HttpResponse, error)

+ func HttpPutJson(url string, data interface{}) (*HttpResponse, error)

+ func ParseHttpResponse(r *http.Response) (*HttpResponse, error)

+ func (res *HttpResponse) GetBody() []byte

+ func (res *HttpResponse) GetBodyString() string

+ func (res *HttpResponse) GetCode() int

+ func (res *HttpResponse) GetHeader(key string) ([]string, bool)

+ type IPVersion uint

+ const IPv4

+ const IPv6

+ type KV interface

+ GetKey func() string

+ GetValue func() string

+ type NetPacketConn interface

+ JoinGroup func(ifi *net.Interface, group net.Addr) error

+ ReadFrom func(buf []byte) (int, net.Addr, error)

+ SetMulticastInterface func(ini *net.Interface) error

+ SetMulticastTTL func(int) error

+ WriteTo func(buf []byte, dst net.Addr) (int, error)

+ type PacketConn4 struct

+ func (pc4 PacketConn4) ReadFrom(buf []byte) (int, net.Addr, error)

+ func (pc4 PacketConn4) WriteTo(buf []byte, dst net.Addr) (int, error)

+ type PacketConn6 struct

+ func (pc6 PacketConn6) ReadFrom(buf []byte) (int, net.Addr, error)

+ func (pc6 PacketConn6) SetMulticastTTL(i int) error

+ func (pc6 PacketConn6) WriteTo(buf []byte, dst net.Addr) (int, error)

+ type TcpClient struct

+ func NewTcpClient(address string, handler TcpHandler) (*TcpClient, error)

+ func (c *TcpClient) Close() error

+ func (c *TcpClient) Start()

+ func (c *TcpClient) Write(out []byte) (int, error)

+ type TcpHandler func([]byte)