zero

Documentation

Index

• Variables
• type Oracle
  • func (o *Oracle) Init()
• type Server
  • func (s *Server) AssignUids(ctx context.Context, num *intern.Num) (*api.AssignedIds, error)
  • func (s *Server) CommitOrAbort(ctx context.Context, src *api.TxnContext) (*api.TxnContext, error)
  • func (s *Server) Connect(ctx context.Context, m *intern.Member) (resp *intern.ConnectionState, err error)
  • func (s *Server) Init()
  • func (s *Server) KnownGroups() []uint32
  • func (s *Server) Leader(gid uint32) *conn.Pool
  • func (s *Server) MarshalMembershipState() ([]byte, error)
  • func (s *Server) Oracle(unused *api.Payload, server intern.Zero_OracleServer) error
  • func (s *Server) ServingTablet(dst string) *intern.Tablet
  • func (s *Server) SetMembershipState(state *intern.MembershipState)
  • func (s *Server) ShouldServe(ctx context.Context, tablet *intern.Tablet) (resp *intern.Tablet, err error)
  • func (s *Server) SyncedUntil() uint64
  • func (s *Server) Timestamps(ctx context.Context, num *intern.Num) (*api.AssignedIds, error)
  • func (s *Server) TryAbort(ctx context.Context, txns *intern.TxnTimestamps) (*intern.TxnTimestamps, error)
  • func (s *Server) Update(stream intern.Zero_UpdateServer) error

Variables

var Zero x.SubCommand

Types

type Oracle

type Oracle struct {
	x.SafeMutex
	// contains filtered or unexported fields
}

func (*Oracle) Init

func (o *Oracle) Init()

type Server

type Server struct {
	x.SafeMutex

	Node *node

	NumReplicas int
	// contains filtered or unexported fields
}

func (*Server) AssignUids

func (s *Server) AssignUids(ctx context.Context, num *intern.Num) (*api.AssignedIds, error)

AssignUids is used to assign new uids by communicating with the leader of the RAFT group responsible for handing out uids.

func (*Server) CommitOrAbort

func (s *Server) CommitOrAbort(ctx context.Context, src *api.TxnContext) (*api.TxnContext, error)

func (*Server) Connect

func (s *Server) Connect(ctx context.Context,
	m *intern.Member) (resp *intern.ConnectionState, err error)

Connect is used to connect the very first time with group zero.

func (*Server) Init

func (s *Server) Init()

func (*Server) KnownGroups

func (s *Server) KnownGroups() []uint32

func (*Server) Leader

func (s *Server) Leader(gid uint32) *conn.Pool

func (*Server) MarshalMembershipState

func (s *Server) MarshalMembershipState() ([]byte, error)

func (*Server) Oracle

func (s *Server) Oracle(unused *api.Payload, server intern.Zero_OracleServer) error

func (*Server) ServingTablet

func (s *Server) ServingTablet(dst string) *intern.Tablet

func (*Server) SetMembershipState

func (s *Server) SetMembershipState(state *intern.MembershipState)

func (*Server) ShouldServe

func (s *Server) ShouldServe(
	ctx context.Context, tablet *intern.Tablet) (resp *intern.Tablet, err error)

func (*Server) SyncedUntil

func (s *Server) SyncedUntil() uint64

func (*Server) Timestamps

func (s *Server) Timestamps(ctx context.Context, num *intern.Num) (*api.AssignedIds, error)

Timestamps is used to assign startTs for a new transaction

func (*Server) TryAbort

func (s *Server) TryAbort(ctx context.Context, txns *intern.TxnTimestamps) (*intern.TxnTimestamps, error)

func (*Server) Update

func (s *Server) Update(stream intern.Zero_UpdateServer) error