SyncGroup

Documentation

Index

• func NewRequest(group, member string, generation int32, assignments []Assignment) *api.Request
• type Assignment
• type Request
• type Response

Functions

func NewRequest

func NewRequest(group, member string, generation int32, assignments []Assignment) *api.Request

Types

type Assignment

type Assignment struct {
	MemberId   string
	Assignment []byte
}

type Request

type Request struct {
	GroupId      string
	GenerationId int32
	MemberId     string
	Assignments  []Assignment
}

type Response

type Response struct {
	ThrottleTimeMs int32
	ErrorCode      int16
	Assignment     []byte
}