backend

Documentation

Index

• type Backend
• type RPC
  • func NewRPC(_ context.Context, addr string, dialOpts ...grpc.DialOption) (*RPC, error)
  • func (r *RPC) GetAllFeedsF(ctx context.Context) func() ([]*entity.Feed, error)
  • func (r *RPC) GetStatsF(ctx context.Context) func() (*entity.Stats, error)
  • func (r *RPC) PullFeedsF(ctx context.Context, ids []entity.ID) func() (<-chan entity.PullResult, error)
  • func (r *RPC) String() string

Types

type Backend

type Backend interface {
	GetStatsF(context.Context) func() (*entity.Stats, error)
	GetAllFeedsF(context.Context) func() ([]*entity.Feed, error)
	PullFeedsF(context.Context, []entity.ID) func() (<-chan entity.PullResult, error)
	String() string
}

Backend describes the console backend.

type RPC

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

func NewRPC

func NewRPC(_ context.Context, addr string, dialOpts ...grpc.DialOption) (*RPC, error)

func (*RPC) GetAllFeedsF

func (r *RPC) GetAllFeedsF(ctx context.Context) func() ([]*entity.Feed, error)

func (*RPC) GetStatsF

func (r *RPC) GetStatsF(ctx context.Context) func() (*entity.Stats, error)

func (*RPC) PullFeedsF

func (r *RPC) PullFeedsF(
	ctx context.Context,
	ids []entity.ID,
) func() (<-chan entity.PullResult, error)

func (*RPC) String

func (r *RPC) String() string