kafsar

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

type Config struct {
	PulsarConfig PulsarConfig
	KafsarConfig KafsarConfig
	TraceConfig  NoErrorTracer
}

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

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

type GroupCoordinator interface {
	HandleJoinGroup(username, groupId, memberId, clientId, protocolType string, sessionTimeoutMs int,
		protocols []*codec.GroupProtocol) (*codec.JoinGroupResp, error)

	HandleSyncGroup(username, groupId, memberId string, generation int,
		groupAssignments []*codec.GroupAssignment) (*codec.SyncGroupResp, error)

	HandleLeaveGroup(username, groupId string, members []*codec.LeaveGroupMember) (*codec.LeaveGroupResp, error)

	HandleHeartBeat(username, groupId, memberId string) *codec.HeartbeatResp

	GetGroup(username, groupId string) (*Group, error)
}

type GroupCoordinatorCluster struct {
}

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

type GroupCoordinatorType int

type GroupStatus int

type KafsarConfig struct {
	// network config
	GnetConfig kgnet.GnetServerConfig
	NeedSasl   bool
	MaxConn    int32

	// Kafka protocol config
	ClusterId     string
	AdvertiseHost string
	AdvertisePort int

	MaxProducerRecordSize int
	MaxBatchSize          int

	MaxConsumersPerGroup     int
	GroupMinSessionTimeoutMs int
	GroupMaxSessionTimeoutMs int
	ConsumerReceiveQueueSize int
	MaxFetchRecord           int
	MinFetchWaitMs           int
	MaxFetchWaitMs           int
	ContinuousOffset         bool
	// PulsarTenant use for kafsar internal
	PulsarTenant string
	// PulsarNamespace use for kafsar internal
	PulsarNamespace string
	// OffsetTopic use to store kafka offset
	OffsetTopic string
	// GroupCoordinatorType enum: Standalone, Cluster; default Standalone
	GroupCoordinatorType GroupCoordinatorType
	// InitialDelayedJoinMs
	InitialDelayedJoinMs int
	// RebalanceTickMs
	RebalanceTickMs int
}

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

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

type MessageIdPair struct {
	MessageId pulsar.MessageID
	Offset    int64
}

type NoErrorTracer interface {
	// IsDisabled check whether tracer disabled
	IsDisabled() bool
	// NewProvider create a trace driver
	NewProvider()
	// NewSpan create span
	NewSpan(ctx context.Context, operateName string, logs ...string) LocalSpan
	// SetAttribute set attribute from localSpan
	SetAttribute(span LocalSpan, k, v string)
	// NewSubSpan create child span from localSpan
	NewSubSpan(span LocalSpan, operateName string, logs ...string) LocalSpan
	// EndSpan close span
	EndSpan(span LocalSpan, logs ...string)
}

type OffsetManager interface {
	Start() chan bool

	CommitOffset(username, kafkaTopic, groupId string, partition int, pair MessageIdPair) error

	AcquireOffset(username, kafkaTopic, groupId string, partition int) (MessageIdPair, bool)

	RemoveOffset(username, kafkaTopic, groupId string, partition int) bool

	GenerateKey(username, kafkaTopic, groupId string, partition int) string

	RemoveOffsetWithKey(key string)

	GetOffsetMap() map[string]MessageIdPair

	Close()
}

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

type OtelTracerConfig TraceConfig

type PulsarConfig struct {
	Host     string
	HttpPort int
	TcpPort  int
}

type Server interface {
	Auth(username string, password string, clientId string) (bool, error)

	AuthTopic(username string, password, clientId, topic, permissionType string) (bool, error)

	AuthTopicGroup(username string, password, clientId, consumerGroup string) (bool, error)

	AuthGroupTopic(topic, groupId string) bool

	SubscriptionName(groupId string) (string, error)

	// PulsarTopic the corresponding topic in pulsar
	PulsarTopic(username, topic string) (string, error)

	PartitionNum(username, topic string) (int, error)

	ListTopic(username string) ([]string, error)

	HasFlowQuota(username, topic string) bool
}

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

type SkywalkingTracerConfig TraceConfig

type TraceConfig struct {
	DisableTracing bool
	Host           string
	Port           int
	SampleRate     float64
}

type TraceType int