Code
Hub
Workspaces
Connect
Indexed graphs
Engine
MCP
copy
hub
/
github.com/travisjeffery/jocko
/ Decoder
Interface
Decoder
protocol/decoder.go:30–32 ·
view source on GitHub ↗
Source
from the content-addressed store, hash-verified
28
}
29
30
type
Decoder
interface
{
31
Decode(d PacketDecoder) error
32
}
33
34
type
PushDecoder
interface
{
35
SaveOffset(in int)
Callers
8
handleRequest
Method · 0.95
Decode
Method · 0.65
Decode
Function · 0.65
Decode
Method · 0.65
Decode
Method · 0.65
Decode
Method · 0.65
handleJoin
Method · 0.65
makeRequest
Method · 0.65
Implementers
15
MessageSet
protocol/message_set.go
LeaveGroupRequest
protocol/leave_group_request.go
APIVersionsResponse
protocol/api_versions_response.go
Message
protocol/message.go
LeaderAndISRResponse
protocol/leader_and_isr_response.go
GroupCoordinatorResponse
protocol/group_coordinator_response.go
RequestHeader
protocol/request_header.go
JoinGroupResponse
protocol/join_group_response.go
GroupCoordinatorRequest
protocol/group_coordinator_request.go
OffsetsRequest
protocol/offsets_request.go
FetchRequest
protocol/fetch_request.go
StopReplicaResponse
protocol/stop_replica_response.go
Calls
no outgoing calls
Tested by
no test coverage detected