assignment

Documentation

Index

• Variables
• type AssignmentServiceImpl
  • func NewAssignmentService(service lazygrpc.Service[streamingpb.StreamingCoordAssignmentServiceClient]) *AssignmentServiceImpl
  • func (c *AssignmentServiceImpl) AssignmentDiscover(ctx context.Context, cb func(*types.VersionedStreamingNodeAssignments) error) error
  • func (c *AssignmentServiceImpl) Close()
  • func (c *AssignmentServiceImpl) ReportAssignmentError(ctx context.Context, pchannel types.PChannelInfo, assignmentErr error) error

Variables

var ErrWatcherClosed = errors.New("watcher is closed")

Types

type AssignmentServiceImpl

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

func NewAssignmentService

func NewAssignmentService(service lazygrpc.Service[streamingpb.StreamingCoordAssignmentServiceClient]) *AssignmentServiceImpl

NewAssignmentService creates a new assignment service.

func (*AssignmentServiceImpl) AssignmentDiscover

func (c *AssignmentServiceImpl) AssignmentDiscover(ctx context.Context, cb func(*types.VersionedStreamingNodeAssignments) error) error

AssignmentDiscover watches the assignment discovery.

func (*AssignmentServiceImpl) Close

func (c *AssignmentServiceImpl) Close()

Close closes the assignment service.

func (*AssignmentServiceImpl) ReportAssignmentError

func (c *AssignmentServiceImpl) ReportAssignmentError(ctx context.Context, pchannel types.PChannelInfo, assignmentErr error) error

ReportAssignmentError reports the assignment error to server.