graceful

Documentation

Overview

Copyright 2009-2016 Weibo, Inc.

All files licensed under the Apache License, Version 2.0 (the "License"); you may not use these files except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2009-2016 Weibo, Inc.

All files licensed under the Apache License, Version 2.0 (the "License"); you may not use these files except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Copyright 2009-2016 Weibo, Inc.

All files licensed under the Apache License, Version 2.0 (the "License"); you may not use these files except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• type ConnectionManager
  • func (cm *ConnectionManager) Add(delt int)
  • func (cm *ConnectionManager) Done()
  • func (cm *ConnectionManager) Wait()
• type Option
• type ServerOption
  • func SetAddr(addrStr string) ServerOption
  • func SetUnixSock(sock string) ServerOption
• type TCPServer
  • func NewTCPServer(opts ...ServerOption) (*TCPServer, error)
  • func NewTCPServerFromFD(fd uintptr) (*TCPServer, error)
  • func (s *TCPServer) AcceptLoop()
  • func (s *TCPServer) ListenerFD() (uintptr, error)
  • func (s *TCPServer) Stop()
  • func (s *TCPServer) Wait()
  • func (s *TCPServer) WaitWithTimeout(duration time.Duration) error

Variables

var (
	ErrWaitTimeout = errors.New("wait timeout")
)

Types

type ConnectionManager

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

func (*ConnectionManager) Add

func (cm *ConnectionManager) Add(delt int)

func (*ConnectionManager) Done

func (cm *ConnectionManager) Done()

func (*ConnectionManager) Wait

func (cm *ConnectionManager) Wait()

type Option

type Option struct {
	Addr     *net.TCPAddr
	SockName string
	Err      error
}

type ServerOption

type ServerOption func(opt *Option)

func SetAddr

func SetAddr(addrStr string) ServerOption

func SetUnixSock

func SetUnixSock(sock string) ServerOption

type TCPServer

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

func NewTCPServer

func NewTCPServer(opts ...ServerOption) (*TCPServer, error)

func NewTCPServerFromFD

func NewTCPServerFromFD(fd uintptr) (*TCPServer, error)

func (*TCPServer) AcceptLoop

func (s *TCPServer) AcceptLoop()

func (*TCPServer) ListenerFD

func (s *TCPServer) ListenerFD() (uintptr, error)

func (*TCPServer) Stop

func (s *TCPServer) Stop()

func (*TCPServer) Wait

func (s *TCPServer) Wait()

func (*TCPServer) WaitWithTimeout

func (s *TCPServer) WaitWithTimeout(duration time.Duration) error