subpub_redis

type IEncoder interface {
	Marshal(v any) ([]byte, error)
}

type IPubSub interface {
	Publish(pid int64, v any) error
	Subscribe()
	Stop()
}

type PubMessage struct {
	Sender string `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Pid    int64  `protobuf:"varint,2,opt,name=Pid,proto3" json:"Pid,omitempty"`
	Data   []byte `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data,omitempty"`
	// contains filtered or unexported fields
}

type PubSub struct {
	Uuid string
	// contains filtered or unexported fields
}