network

Documentation

Index

• func ConvertToAppendRequest(bufferName, target string, args *rafthashi.AppendEntriesRequest) *intra.AppendEntriesRequest
• func SetRPCFromAppendResp(resp *intra.AppendEntriesResponse, rpc *rafthashi.AppendEntriesResponse)
• type ClientCache
  • func NewClientCache() *ClientCache
  • func (c *ClientCache) Fetch(target string) intra.NodeRaftClient
• type IOFetcher
• type Inbound
  • func NewInbound(addr string, schedulerHandler intra.NodeServer) *Inbound
  • func (i *Inbound) Addr() string
  • func (i *Inbound) AppendEntries(ctx context.Context, in *intra.AppendEntriesRequest) (resp *intra.AppendEntriesResponse, err error)
  • func (i *Inbound) Fetch(bufferName string) <-chan rafthashi.RPC
  • func (i *Inbound) RequestVote(ctx context.Context, in *intra.RequestVoteRequest) (resp *intra.RequestVoteResponse, err error)
• type Pipeline
  • func NewPipeline(bufferName, target string, client intra.NodeRaftClient) *Pipeline
  • func (p *Pipeline) AppendEntries(args *rafthashi.AppendEntriesRequest, resp *rafthashi.AppendEntriesResponse) (rafthashi.AppendFuture, error)
  • func (p *Pipeline) Close() error
  • func (p *Pipeline) Consumer() <-chan rafthashi.AppendFuture
• type SchedulerInbound
  • func NewSchedulerInbound(externalAddr string, ioFetcher IOFetcher) *SchedulerInbound
  • func (i *SchedulerInbound) Create(ctx context.Context, in *intra.CreateInfo) (*intra.CreateResponse, error)
  • func (i *SchedulerInbound) Leader(ctx context.Context, in *intra.LeaderRequest) (*intra.LeaderResponse, error)
  • func (i *SchedulerInbound) Status(ctx context.Context, in *intra.StatusRequest) (*intra.StatusResponse, error)
  • func (i *SchedulerInbound) UpdateConfig(ctx context.Context, in *intra.UpdateConfigRequest) (*intra.UpdateConfigResponse, error)

Functions

func ConvertToAppendRequest

func ConvertToAppendRequest(bufferName, target string, args *rafthashi.AppendEntriesRequest) *intra.AppendEntriesRequest

func SetRPCFromAppendResp

func SetRPCFromAppendResp(resp *intra.AppendEntriesResponse, rpc *rafthashi.AppendEntriesResponse)

Types

type ClientCache

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

func NewClientCache

func NewClientCache() *ClientCache

func (*ClientCache) Fetch

func (c *ClientCache) Fetch(target string) intra.NodeRaftClient

type IOFetcher

type IOFetcher interface {
	Create(name string, bufferSize uint64, peers []string) error
	Leader(name string) (string, error)
	Status() map[string][]string
	SetExpectedPeers(name string, expectedPeers []string) error
}

type Inbound

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

func NewInbound

func NewInbound(addr string, schedulerHandler intra.NodeServer) *Inbound

func (*Inbound) Addr

func (i *Inbound) Addr() string

func (*Inbound) AppendEntries

func (i *Inbound) AppendEntries(ctx context.Context, in *intra.AppendEntriesRequest) (resp *intra.AppendEntriesResponse, err error)

func (*Inbound) Fetch

func (i *Inbound) Fetch(bufferName string) <-chan rafthashi.RPC

func (*Inbound) RequestVote

func (i *Inbound) RequestVote(ctx context.Context, in *intra.RequestVoteRequest) (resp *intra.RequestVoteResponse, err error)

type Pipeline

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

func NewPipeline

func NewPipeline(bufferName, target string, client intra.NodeRaftClient) *Pipeline

func (*Pipeline) AppendEntries

func (p *Pipeline) AppendEntries(args *rafthashi.AppendEntriesRequest, resp *rafthashi.AppendEntriesResponse) (rafthashi.AppendFuture, error)

func (*Pipeline) Close

func (p *Pipeline) Close() error

func (*Pipeline) Consumer

func (p *Pipeline) Consumer() <-chan rafthashi.AppendFuture

type SchedulerInbound

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

func NewSchedulerInbound

func NewSchedulerInbound(externalAddr string, ioFetcher IOFetcher) *SchedulerInbound

func (*SchedulerInbound) Create

func (i *SchedulerInbound) Create(ctx context.Context, in *intra.CreateInfo) (*intra.CreateResponse, error)

func (*SchedulerInbound) Leader

func (i *SchedulerInbound) Leader(ctx context.Context, in *intra.LeaderRequest) (*intra.LeaderResponse, error)

func (*SchedulerInbound) Status

func (i *SchedulerInbound) Status(ctx context.Context, in *intra.StatusRequest) (*intra.StatusResponse, error)

func (*SchedulerInbound) UpdateConfig

func (i *SchedulerInbound) UpdateConfig(ctx context.Context, in *intra.UpdateConfigRequest) (*intra.UpdateConfigResponse, error)