JoinGroup

Documentation

Index

• func NewRequest(group, member, protocol string, protocols []Protocol) *api.Request
• type Member
• type Protocol
• type Request
• type Response

Functions

func NewRequest

func NewRequest(group, member, protocol string, protocols []Protocol) *api.Request

Types

type Member

type Member struct {
	MemberId string
	Metadata []byte
}

type Protocol

type Protocol struct {
	Name     string
	Metadata []byte
}

type Request

type Request struct {
	GroupId            string
	SessionTimeoutMs   int32
	RebalanceTimeoutMs int32
	MemberId           string
	ProtocolType       string
	Protocols          []Protocol
}

type Response

type Response struct {
	ThrottleTimeMs int32
	ErrorCode      int16
	GenerationId   int32
	ProtocolName   string
	Leader         string
	MemberId       string
	Members        []Member // for leader this will not be empty
}