MCPcopy
hub / github.com/milvus-io/milvus / UnmarshalDispatcher

Interface UnmarshalDispatcher

pkg/mq/msgstream/unmarshal.go:28–30  ·  view source on GitHub ↗

UnmarshalDispatcher is an interface contains method Unmarshal

Source from the content-addressed store, hash-verified

26
27// UnmarshalDispatcher is an interface contains method Unmarshal
28type UnmarshalDispatcher interface {
29 Unmarshal(input interface{}, msgType commonpb.MsgType) (TsMsg, error)
30}
31
32// UnmarshalDispatcherFactory is a factory to generate an object which implement interface UnmarshalDispatcher
33type UnmarshalDispatcherFactory interface {

Callers 1

Implementers 15

ResultSetclient/milvusclient/results.go
MarshalFailTsMsgpkg/mq/msgstream/mq_msgstream_test.go
CreateDatabaseMsgpkg/mq/msgstream/msg_for_database.go
DropDatabaseMsgpkg/mq/msgstream/msg_for_database.go
AlterDatabaseMsgpkg/mq/msgstream/msg_for_database.go
LoadCollectionMsgpkg/mq/msgstream/msg_for_collection.go
ReleaseCollectionMsgpkg/mq/msgstream/msg_for_collection.go
FlushMsgpkg/mq/msgstream/msg_for_collection.go
AlterCollectionMsgpkg/mq/msgstream/msg_for_collection.go
AlterCollectionFieldMsgpkg/mq/msgstream/msg_for_collection.go
RenameCollectionMsgpkg/mq/msgstream/msg_for_collection.go
ProtoUnmarshalDispatcherpkg/mq/msgstream/unmarshal.go

Calls

no outgoing calls

Tested by

no test coverage detected

Used in the wild real call sites across dependent graphs

searching dependent graphs…