api

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 2, 2022 License: MIT Imports: 18 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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 added in v0.2.0 

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 added in v0.2.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.