Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

server

package

Go to main page

Versions in this module

v1

v1.8.0

Apr 26, 2026

v1.7.0

Apr 25, 2026

v1.5.0

Apr 18, 2026

v1.4.0

Apr 18, 2026

Changes in this version

+ func ListenWithRetry(addr string) (net.Listener, error)

+ func RunGRPCServer(ctx context.Context, lis net.Listener, srv *PaxosServer) error

+ type BaseData struct

+ ActiveNav string

+ AgentName string

+ Title string

+ type CommandData struct

+ Key string

+ Value string

+ type GRPCChannelData struct

+ CallsFailed int64

+ CallsStarted int64

+ CallsSucceeded int64

+ ChannelID int64

+ State string

+ Target string

+ type GRPCServerData struct

+ CallsFailed int64

+ CallsStarted int64

+ CallsSucceeded int64

+ LastCall string

+ ServerID int64

+ type GRPCStatusData struct

+ Channels []GRPCChannelData

+ ErrorMsg template.HTML

+ Servers []GRPCServerData

+ type HTTPServer struct

+ func NewHTTPServer(addr string, store *state.Store, cell *paxos.Cell) *HTTPServer

+ func (s *HTTPServer) Run(lis net.Listener) error

+ type IndexData struct

+ AgentCert string

+ AgentID template.HTML

+ KeysCount int

+ Participants []Participant

+ type KV struct

+ Key template.HTML

+ Type string

+ Value template.HTML

+ Version uint64

+ type KnownPeer struct

+ CertPEM string

+ GRPCURL string

+ HTTPLink template.HTML

+ HasCert bool

+ ID string

+ Name string

+ type Message struct

+ ID int64

+ Receiver string

+ Reply template.HTML

+ Request template.HTML

+ Sender string

+ Timestamp string

+ Type string

+ type MessagesData struct

+ Messages []Message

+ Peers []Peer

+ type OngoingRequest struct

+ Finished bool

+ ID string

+ Key string

+ Result string

+ StartTime time.Time

+ Success bool

+ Type string

+ type Participant struct

+ GRPCAddr string

+ HTTPLink template.HTML

+ IDLabel template.HTML

+ ShortName string

+ type PaxosClient struct

+ func NewPaxosClient(agentID string, addr string) (*PaxosClient, error)

+ func (c *PaxosClient) Accept(ctx context.Context, req *paxosv1.AcceptRequest) (*paxosv1.AcceptedResponse, error)

+ func (c *PaxosClient) AgentID() string

+ func (c *PaxosClient) Close() error

+ func (c *PaxosClient) GetKVEntry(ctx context.Context, req *paxosv1.GetKVEntryRequest) (*paxosv1.GetKVEntryResponse, error)

+ func (c *PaxosClient) GetPeerEndpoints(ctx context.Context, req *paxosv1.GetPeerEndpointsRequest) (*paxosv1.GetPeerEndpointsResponse, error)

+ func (c *PaxosClient) JoinCluster(ctx context.Context, req *paxosv1.JoinClusterRequest) (*paxosv1.JoinClusterResponse, error)

+ func (c *PaxosClient) Ping(ctx context.Context, req *paxosv1.PingRequest) (*paxosv1.PingResponse, error)

+ func (c *PaxosClient) Prepare(ctx context.Context, req *paxosv1.PrepareRequest) (*paxosv1.PromiseResponse, error)

+ func (c *PaxosClient) Sync(ctx context.Context, req *paxosv1.SyncRequest) (*paxosv1.SyncResponse, error)

+ type PaxosServer struct

+ func NewPaxosServer(agentID string, ident *identity.Identity, store *state.Store, ...) *PaxosServer

+ func (s *PaxosServer) Accept(ctx context.Context, req *paxosv1.AcceptRequest) (*paxosv1.AcceptedResponse, error)

+ func (s *PaxosServer) AcquireLock(ctx context.Context, req *paxosv1.AcquireLockRequest) (*paxosv1.AcquireLockResponse, error)

+ func (s *PaxosServer) CompareAndWrite(ctx context.Context, req *paxosv1.CompareAndWriteRequest) (*paxosv1.CompareAndWriteResponse, error)

+ func (s *PaxosServer) GetKVEntry(ctx context.Context, req *paxosv1.GetKVEntryRequest) (*paxosv1.GetKVEntryResponse, error)

+ func (s *PaxosServer) GetPeerEndpoints(ctx context.Context, req *paxosv1.GetPeerEndpointsRequest) (*paxosv1.GetPeerEndpointsResponse, error)

+ func (s *PaxosServer) JoinCluster(ctx context.Context, req *paxosv1.JoinClusterRequest) (*paxosv1.JoinClusterResponse, error)

+ func (s *PaxosServer) Ping(ctx context.Context, req *paxosv1.PingRequest) (*paxosv1.PingResponse, error)

+ func (s *PaxosServer) Prepare(ctx context.Context, req *paxosv1.PrepareRequest) (*paxosv1.PromiseResponse, error)

+ func (s *PaxosServer) Read(ctx context.Context, req *paxosv1.ReadRequest) (*paxosv1.ReadResponse, error)

+ func (s *PaxosServer) ReadPrefix(ctx context.Context, req *paxosv1.ReadPrefixRequest) (*paxosv1.ReadPrefixResponse, error)

+ func (s *PaxosServer) ReleaseLock(ctx context.Context, req *paxosv1.ReleaseLockRequest) (*paxosv1.ReleaseLockResponse, error)

+ func (s *PaxosServer) RenewLock(ctx context.Context, req *paxosv1.RenewLockRequest) (*paxosv1.RenewLockResponse, error)

+ func (s *PaxosServer) Shutdown(ctx context.Context, req *paxosv1.ShutdownRequest) (*paxosv1.ShutdownResponse, error)

+ func (s *PaxosServer) Sync(ctx context.Context, req *paxosv1.SyncRequest) (*paxosv1.SyncResponse, error)

+ type Peer struct

+ AgentID string

+ Endpoints template.HTML

+ Label template.HTML

+ type PeersData struct

+ Peers []KnownPeer

+ type StoreData struct

+ KVs []KV

+ type SystemData struct

+ Alloc uint64

+ AllocMB float64

+ Dump string

+ NumCPU int

+ NumGC uint32

+ NumGoroutines int

+ ShowDump bool

+ Sys uint64

+ SysMB float64

+ TotalAlloc uint64

+ TotalAllocMB float64

+ type UserAPIData struct

+ OngoingHTML template.HTML

+ StatusMsg template.HTML

v1.3.0

Mar 30, 2026

v1.2.0

Mar 30, 2026

v1.1.0

Mar 30, 2026

v1.0.0

Mar 29, 2026

v0

v0.4.0

Mar 28, 2026

v0.3.0

Mar 28, 2026

v0.2.0

Mar 28, 2026

v0.1.0

Mar 28, 2026