api

Documentation

Index

• func NewQueue(fm *feeds.Manager, tasks *storage.TaskStore, raft *raft.Raft, ...) proto.QueueServer
• type Admin
  • func NewAdmin(raft *raft.Raft, cfg cluster.PeerConfig, handle *cluster.LeaderHandle, ...) *Admin
  • func (a *Admin) AddClusterMember(ctx context.Context, req *proto.AddClusterMemberRequest) (*emptypb.Empty, error)
  • func (a *Admin) BootstrapCluster(ctx context.Context, e *emptypb.Empty) (*emptypb.Empty, error)
  • func (a *Admin) CheckHealth(ctx context.Context, req *proto.CheckHealthRequest) (*proto.Status, error)
  • func (a *Admin) GetClusterInfo(ctx context.Context, req *proto.GetClusterInfoRequest) (*proto.ClusterInfo, error)
  • func (a *Admin) GetQueue(ctx context.Context, req *proto.GetQueueRequest) (*proto.QueueConfig, error)
  • func (a *Admin) RemoveClusterMember(ctx context.Context, req *proto.RemoveClusterMemberRequest) (*emptypb.Empty, error)
  • func (a *Admin) UpdateQueue(ctx context.Context, req *proto.UpdateQueueRequest) (*proto.QueueConfig, error)
• type Queue
  • func (q *Queue) Delete(ctx context.Context, req *proto.DeleteTaskRequest) (*proto.DeleteTaskResponse, error)
  • func (q *Queue) GetTask(ctx context.Context, req *proto.GetTaskRequest) (*proto.Task, error)
  • func (q *Queue) Pull(stream proto.Queue_PullServer) error
  • func (q *Queue) Push(ctx context.Context, req *proto.PushTaskRequest) (*proto.PushTaskResponse, error)
  • func (q *Queue) PushStream(stream proto.Queue_PushStreamServer) error

Functions

func NewQueue

func NewQueue(
	fm *feeds.Manager,
	tasks *storage.TaskStore,
	raft *raft.Raft,
	handle *cluster.LeaderHandle,
	ids *storage.IDGenerator,
) proto.QueueServer

Types

type Admin

type Admin struct {
	proto.UnimplementedAdminServer
	// contains filtered or unexported fields
}

Admin implements the gRPC Admin service.

func NewAdmin

func NewAdmin(
	raft *raft.Raft,
	cfg cluster.PeerConfig,
	handle *cluster.LeaderHandle,
	fm *feeds.Manager,
	ids *storage.IDGenerator,
) *Admin

func (*Admin) AddClusterMember

func (a *Admin) AddClusterMember(
	ctx context.Context,
	req *proto.AddClusterMemberRequest,
) (*emptypb.Empty, error)

func (*Admin) BootstrapCluster

func (a *Admin) BootstrapCluster(ctx context.Context, e *emptypb.Empty) (*emptypb.Empty, error)

func (*Admin) CheckHealth

func (a *Admin) CheckHealth(
	ctx context.Context,
	req *proto.CheckHealthRequest,
) (*proto.Status, error)

func (*Admin) GetClusterInfo

func (a *Admin) GetClusterInfo(
	ctx context.Context,
	req *proto.GetClusterInfoRequest,
) (*proto.ClusterInfo, error)

func (*Admin) GetQueue

func (a *Admin) GetQueue(ctx context.Context, req *proto.GetQueueRequest) (*proto.QueueConfig, error)

func (*Admin) RemoveClusterMember

func (a *Admin) RemoveClusterMember(
	ctx context.Context,
	req *proto.RemoveClusterMemberRequest,
) (*emptypb.Empty, error)

func (*Admin) UpdateQueue

func (a *Admin) UpdateQueue(ctx context.Context, req *proto.UpdateQueueRequest) (*proto.QueueConfig, error)

type Queue

type Queue struct {
	proto.UnimplementedQueueServer
	// contains filtered or unexported fields
}

Queue implements the gRPC Queue service.

func (*Queue) Delete

func (q *Queue) Delete(ctx context.Context, req *proto.DeleteTaskRequest) (*proto.DeleteTaskResponse, error)

func (*Queue) GetTask

func (q *Queue) GetTask(ctx context.Context, req *proto.GetTaskRequest) (*proto.Task, error)

func (*Queue) Pull

func (q *Queue) Pull(stream proto.Queue_PullServer) error

func (*Queue) Push

func (q *Queue) Push(ctx context.Context, req *proto.PushTaskRequest) (*proto.PushTaskResponse, error)

func (*Queue) PushStream

func (q *Queue) PushStream(stream proto.Queue_PushStreamServer) error